Uses of Interface
net.sf.xenqtt.message.MessageHandler

Packages that use MessageHandler

net.sf.xenqtt
net.sf.xenqtt.message

Uses of MessageHandler in net.sf.xenqtt

Methods in net.sf.xenqtt with parameters of type MessageHandler

void	SimpleBroker.init(MessageHandler messageHandler, String serverThreadName) Starts the broker.

Uses of MessageHandler in net.sf.xenqtt.message

Methods in net.sf.xenqtt.message with parameters of type MessageHandler

void	ChannelManagerImpl.attachChannel(MqttChannelRef channel, MessageHandler messageHandler)
void	ChannelManager.attachChannel(MqttChannelRef channel, MessageHandler messageHandler) Attaches the specified channel to this manager's control.
MqttChannelRef	ChannelManagerImpl.newBrokerChannel(SocketChannel socketChannel, MessageHandler messageHandler)
MqttChannelRef	ChannelManager.newBrokerChannel(SocketChannel socketChannel, MessageHandler messageHandler) Create a new broker side MqttChannelRef for use in exchanging data using the MQTT protocol.
MqttChannelRef	ChannelManagerImpl.newClientChannel(String host, int port, MessageHandler messageHandler)
MqttChannelRef	ChannelManager.newClientChannel(String host, int port, MessageHandler messageHandler) Create a new client side MqttChannelRef for use in exchanging data using the MQTT protocol.
MqttChannelRef	ChannelManagerImpl.newClientChannel(String brokerUri, MessageHandler messageHandler)
MqttChannelRef	ChannelManager.newClientChannel(String brokerUri, MessageHandler messageHandler) Create a new client side MqttChannelRef for use in exchanging data using the MQTT protocol.
MqttChannelRef	ChannelManagerImpl.newClientChannel(URI brokerUri, MessageHandler messageHandler)
MqttChannelRef	ChannelManager.newClientChannel(URI brokerUri, MessageHandler messageHandler) Create a new client side MqttChannelRef for use in exchanging data using the MQTT protocol.
boolean	MqttChannel.register(Selector selector, MessageHandler handler) Registers this channel with the specified selector.

Constructors in net.sf.xenqtt.message with parameters of type MessageHandler

MqttBrokerChannel(SocketChannel channel, MessageHandler handler, Selector selector, long messageResendIntervalMillis, net.sf.xenqtt.message.MutableMessageStats stats)

MqttClientChannel(String host, int port, MessageHandler handler, Selector selector, long messageResendIntervalMillis, BlockingCommand<?> connectionCompleteCommand, net.sf.xenqtt.message.MutableMessageStats stats)
Starts an asynchronous connection to the specified host and port.