Package br.com.anteros.mqtt.core.server

Class MqttServerAioListener

java.lang.Object

org.tio.core.DefaultAioListener

br.com.anteros.mqtt.core.server.MqttServerAioListener

All Implemented Interfaces:

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

public class MqttServerAioListener
extends org.tio.core.DefaultAioListener

mqtt 服务监听

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
MqttServerAioListener(MqttServerCreator serverCreator, ScheduledThreadPoolExecutor executor)

Method Summary

Modifier and Type	Method	Description
void	onAfterSent(org.tio.core.ChannelContext context, org.tio.core.intf.Packet packet, boolean isSentSuccess)
void	onBeforeClose(org.tio.core.ChannelContext context, Throwable throwable, String remark, boolean isRemove)
boolean	onHeartbeatTimeout(org.tio.core.ChannelContext context, Long interval, int heartbeatTimeoutCount)

Methods inherited from class org.tio.core.DefaultAioListener

onAfterConnected, onAfterDecoded, onAfterHandled, onAfterReceivedBytes

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttServerAioListener

public MqttServerAioListener(MqttServerCreator serverCreator,
                             ScheduledThreadPoolExecutor executor)

Method Detail

onHeartbeatTimeout

public boolean onHeartbeatTimeout(org.tio.core.ChannelContext context,
                                  Long interval,
                                  int heartbeatTimeoutCount)

Specified by:

onHeartbeatTimeout in interface org.tio.server.intf.ServerAioListener

Overrides:

onHeartbeatTimeout in class org.tio.core.DefaultAioListener

onBeforeClose

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

Specified by:

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

Overrides:

onBeforeClose in class org.tio.core.DefaultAioListener

onAfterSent

public void onAfterSent(org.tio.core.ChannelContext context,
                        org.tio.core.intf.Packet packet,
                        boolean isSentSuccess)

Specified by:

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

Overrides:

onAfterSent in class org.tio.core.DefaultAioListener