Package br.com.anteros.mqtt.core.client

Class MqttClientAioHandler

java.lang.Object

br.com.anteros.mqtt.core.client.MqttClientAioHandler

All Implemented Interfaces:

org.tio.client.intf.ClientAioHandler, org.tio.core.intf.AioHandler

public class MqttClientAioHandler
extends Object
implements org.tio.client.intf.ClientAioHandler

mqtt 客户端处理

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
MqttClientAioHandler(MqttClientCreator mqttClientCreator, IMqttClientProcessor processor)

Method Summary

Modifier and Type	Method	Description
org.tio.core.intf.Packet	decode(ByteBuffer buffer, int limit, int position, int readableLength, org.tio.core.ChannelContext context)
ByteBuffer	encode(org.tio.core.intf.Packet packet, org.tio.core.TioConfig tioConfig, org.tio.core.ChannelContext channelContext)
void	handler(org.tio.core.intf.Packet packet, org.tio.core.ChannelContext context)
org.tio.core.intf.Packet	heartbeatPacket(org.tio.core.ChannelContext channelContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MqttClientAioHandler

public MqttClientAioHandler(MqttClientCreator mqttClientCreator,
                            IMqttClientProcessor processor)

Method Detail

heartbeatPacket

public org.tio.core.intf.Packet heartbeatPacket(org.tio.core.ChannelContext channelContext)

Specified by:

heartbeatPacket in interface org.tio.client.intf.ClientAioHandler

decode

public org.tio.core.intf.Packet decode(ByteBuffer buffer,
                                       int limit,
                                       int position,
                                       int readableLength,
                                       org.tio.core.ChannelContext context)
                                throws org.tio.core.exception.TioDecodeException

Specified by:

decode in interface org.tio.core.intf.AioHandler

Throws:

org.tio.core.exception.TioDecodeException

encode

public ByteBuffer encode(org.tio.core.intf.Packet packet,
                         org.tio.core.TioConfig tioConfig,
                         org.tio.core.ChannelContext channelContext)

Specified by:

encode in interface org.tio.core.intf.AioHandler

handler

public void handler(org.tio.core.intf.Packet packet,
                    org.tio.core.ChannelContext context)

Specified by:

handler in interface org.tio.core.intf.AioHandler