net.sf.xenqtt.proxy
Class ProxyBroker

java.lang.Object
  net.sf.xenqtt.SimpleBroker
      net.sf.xenqtt.proxy.ProxyBroker

All Implemented Interfaces:

MessageHandler

public class ProxyBroker
extends SimpleBroker
implements MessageHandler

SimpleBroker extension that handles creating/managing sessions.

Field Summary

Fields inherited from class net.sf.xenqtt.SimpleBroker

manager

Constructor Summary

ProxyBroker(String brokerUri, int port, int maxInFlightBrokerMessages)

Method Summary

void	channelAttached(MqttChannel channel) Called when an MQTT channel is attached to a channel manager.
void	channelClosed(MqttChannel channel, Throwable cause) Called when an MQTT channel is formally closed.
void	channelDetached(MqttChannel channel) Called when an MQTT channel is detached from a channel manager.
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	init() Initializes the broker
void	messageSent(MqttChannel channel, MqttMessage message) Called when a message is sent from the client
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
boolean	shutdown(long millis) Shuts down the broker.
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 net.sf.xenqtt.SimpleBroker

getPort, getURI, init

Methods inherited from class java.lang.Object

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

Constructor Detail

ProxyBroker

public ProxyBroker(String brokerUri,
                   int port,
                   int maxInFlightBrokerMessages)

Parameters:

brokerUri - The URI of the broker the proxy should connect to

port - The port for the server to listen on. 0 will choose an arbitrary available port which you can get from SimpleBroker.getPort() after calling init().

maxInFlightBrokerMessages - Maximum number of messages that may be in-flight to the broker at a time

Method Detail

init

public void init()

Initializes the broker

shutdown

public boolean shutdown(long millis)

Description copied from class: SimpleBroker

Shuts down the broker. Blocks until shutdown is complete.

Overrides:

shutdown in class SimpleBroker

Parameters:

millis - Milliseconds to wait for shutdown to complete. 0 means to wait forever.

Returns:

true if shutdown is successful, otherwise false.

See Also:

SimpleBroker.shutdown(long)

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 an 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)

channelAttached

public void channelAttached(MqttChannel channel)

Description copied from interface: MessageHandler

Called when an MQTT channel is attached to a channel manager.

Specified by:

channelAttached in interface MessageHandler

Parameters:

channel - The channel that was attached

See Also:

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

channelDetached

public void channelDetached(MqttChannel channel)

Description copied from interface: MessageHandler

Called when an MQTT channel is detached from a channel manager.

Specified by:

channelDetached in interface MessageHandler

Parameters:

channel - The channel that was detached

See Also:

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

messageSent

public void messageSent(MqttChannel channel,
                        MqttMessage message)

Description copied from interface: MessageHandler

Called when a message is sent from the client

Specified by:

messageSent in interface MessageHandler

Parameters:

channel - The channel on which the message was sent

message - The message that was sent

See Also:

MessageHandler.messageSent(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.MqttMessage)