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

Class MqttClientAioListener

java.lang.Object

org.tio.core.DefaultAioListener

org.tio.client.DefaultClientAioListener

br.com.anteros.mqtt.core.client.MqttClientAioListener

All Implemented Interfaces:

org.tio.client.intf.ClientAioListener, org.tio.core.intf.AioListener, org.tio.server.intf.ServerAioListener

public class MqttClientAioListener
extends org.tio.client.DefaultClientAioListener

mqtt 客户端监听器

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
MqttClientAioListener(MqttClientCreator clientCreator)

Method Summary

Modifier and Type	Method	Description
void	onAfterConnected(org.tio.core.ChannelContext context, boolean isConnected, boolean isReconnect)
void	onBeforeClose(org.tio.core.ChannelContext channelContext, Throwable throwable, String remark, boolean isRemove)

Methods inherited from class org.tio.core.DefaultAioListener

onAfterDecoded, onAfterHandled, onAfterReceivedBytes, onAfterSent, onHeartbeatTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttClientAioListener

public MqttClientAioListener(MqttClientCreator clientCreator)

Method Detail

onAfterConnected

public void onAfterConnected(org.tio.core.ChannelContext context,
                             boolean isConnected,
                             boolean isReconnect)

Specified by:

onAfterConnected in interface org.tio.core.intf.AioListener

Overrides:

onAfterConnected in class org.tio.core.DefaultAioListener

onBeforeClose

public void onBeforeClose(org.tio.core.ChannelContext channelContext,
                          Throwable throwable,
                          String remark,
                          boolean isRemove)

Specified by:

onBeforeClose in interface org.tio.core.intf.AioListener

Overrides:

onBeforeClose in class org.tio.core.DefaultAioListener