net.sf.xenqtt.proxy
Class ServerMessageHandler

java.lang.Object
  net.sf.xenqtt.proxy.ServerMessageHandler

All Implemented Interfaces:

MessageHandler

public final class ServerMessageHandler
extends Object
implements MessageHandler

Handles messages from proxy server clients before they are assigned to a cluster

Constructor Summary

ServerMessageHandler()

Method Summary

void	channelClosed(MqttChannel channel, Throwable cause) Called when a MQTT channel is formally closed.
void	channelOpened(MqttChannel channel) Called when a MQTT channel is opened.
void	connAck(MqttChannel channel, ConnAckMessage message) Called when a ConnAckMessage is received through the specified channel
void	connect(MqttChannel channel, ConnectMessage message) Called when a ConnectMessage is received through the specified channel
void	disconnect(MqttChannel channel, DisconnectMessage message) Called when a DisconnectMessage is received through the specified channel
void	pubAck(MqttChannel channel, PubAckMessage message) Called when a PubAckMessage is received through the specified channel
void	pubComp(MqttChannel channel, PubCompMessage message) Called when a PubCompMessage is received through the specified channel
void	publish(MqttChannel channel, PubMessage message) Called when a PubMessage is received through the specified channel
void	pubRec(MqttChannel channel, PubRecMessage message) Called when a PubRecMessage is received through the specified channel
void	pubRel(MqttChannel channel, PubRelMessage message) Called when a PubRelMessage is received through the specified channel
void	subAck(MqttChannel channel, SubAckMessage message) Called when a SubAckMessage is received through the specified channel
void	subscribe(MqttChannel channel, SubscribeMessage message) Called when a SubscribeMessage is received through the specified channel
void	unsubAck(MqttChannel channel, UnsubAckMessage message) Called when a UnsubAckMessage is received through the specified channel
void	unsubscribe(MqttChannel channel, UnsubscribeMessage message) Called when a UnsubscribeMessage is received through the specified channel

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerMessageHandler

public ServerMessageHandler()

Method Detail

connect

public void connect(MqttChannel channel,
                    ConnectMessage message)
             throws Exception

Description copied from interface: MessageHandler

Called when a ConnectMessage is received through the specified channel

Specified by:

connect in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.connect(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.ConnectMessage)

connAck

public void connAck(MqttChannel channel,
                    ConnAckMessage message)
             throws Exception

Description copied from interface: MessageHandler

Called when a ConnAckMessage is received through the specified channel

Specified by:

connAck in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.connAck(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.ConnAckMessage)

publish

public void publish(MqttChannel channel,
                    PubMessage message)
             throws Exception

Description copied from interface: MessageHandler

Called when a PubMessage is received through the specified channel

Specified by:

publish in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.publish(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.PubMessage)

pubAck

public void pubAck(MqttChannel channel,
                   PubAckMessage message)
            throws Exception

Description copied from interface: MessageHandler

Called when a PubAckMessage is received through the specified channel

Specified by:

pubAck in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.pubAck(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.PubAckMessage)

pubRec

public void pubRec(MqttChannel channel,
                   PubRecMessage message)
            throws Exception

Description copied from interface: MessageHandler

Called when a PubRecMessage is received through the specified channel

Specified by:

pubRec in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.pubRec(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.PubRecMessage)

pubRel

public void pubRel(MqttChannel channel,
                   PubRelMessage message)
            throws Exception

Description copied from interface: MessageHandler

Called when a PubRelMessage is received through the specified channel

Specified by:

pubRel in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.pubRel(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.PubRelMessage)

pubComp

public void pubComp(MqttChannel channel,
                    PubCompMessage message)
             throws Exception

Description copied from interface: MessageHandler

Called when a PubCompMessage is received through the specified channel

Specified by:

pubComp in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.pubComp(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.PubCompMessage)

subscribe

public void subscribe(MqttChannel channel,
                      SubscribeMessage message)
               throws Exception

Description copied from interface: MessageHandler

Called when a SubscribeMessage is received through the specified channel

Specified by:

subscribe in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.subscribe(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.SubscribeMessage)

subAck

public void subAck(MqttChannel channel,
                   SubAckMessage message)
            throws Exception

Description copied from interface: MessageHandler

Called when a SubAckMessage is received through the specified channel

Specified by:

subAck in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.subAck(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.SubAckMessage)

unsubscribe

public void unsubscribe(MqttChannel channel,
                        UnsubscribeMessage message)
                 throws Exception

Description copied from interface: MessageHandler

Called when a UnsubscribeMessage is received through the specified channel

Specified by:

unsubscribe in interface MessageHandler

Throws:

Exception

unsubAck

public void unsubAck(MqttChannel channel,
                     UnsubAckMessage message)
              throws Exception

Description copied from interface: MessageHandler

Called when a UnsubAckMessage is received through the specified channel

Specified by:

unsubAck in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.unsubAck(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.UnsubAckMessage)

disconnect

public void disconnect(MqttChannel channel,
                       DisconnectMessage message)
                throws Exception

Description copied from interface: MessageHandler

Called when a DisconnectMessage is received through the specified channel

Specified by:

disconnect in interface MessageHandler

Throws:

Exception

See Also:

MessageHandler.disconnect(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.DisconnectMessage)

channelOpened

public void channelOpened(MqttChannel channel)

Description copied from interface: MessageHandler

Called when a MQTT channel is opened. Opened is when the connection to the broker or from the client has been established but before any messages have been sent.

Specified by:

channelOpened in interface MessageHandler

Parameters:

channel - The channel that was opened.

See Also:

MessageHandler.channelOpened(net.sf.xenqtt.message.MqttChannel)

channelClosed

public void channelClosed(MqttChannel channel,
                          Throwable cause)

Description copied from interface: MessageHandler

Called when a MQTT channel is formally closed.

Specified by:

channelClosed in interface MessageHandler

Parameters:

channel - The channel that was closed

cause - The reason the channel was closed. Null if the channel was not closed because of an exception.

See Also:

MessageHandler.channelClosed(net.sf.xenqtt.message.MqttChannel, java.lang.Throwable)