net.sf.xenqtt.mockbroker
Class MockBrokerHandler

java.lang.Object
  net.sf.xenqtt.mockbroker.MockBrokerHandler

public class MockBrokerHandler
extends Object

This class does nothing by default. You can extend it to add functionality to the MockMqttBroker, mock it with Mockito or another mocking framework, etc. If the method returns false then the default behavior for that event is executed. If the method returns true it is not.

Constructor Summary

MockBrokerHandler()

Method Summary

void	channelClosed(Client client, Throwable cause)
void	channelOpened(Client client)
boolean	connect(Client client, ConnectMessage message)
void	disconnect(Client client, DisconnectMessage message)
boolean	pubAck(Client client, PubAckMessage message)
boolean	pubComp(Client client, PubCompMessage message)
boolean	publish(Client client, PubMessage message)
boolean	pubRec(Client client, PubRecMessage message)
boolean	pubRel(Client client, PubRelMessage message)
boolean	subscribe(Client client, SubscribeMessage message)
void	unexpectedMessage(Client client, MqttMessage message) Called when an unexpected message is received.
boolean	unsubscribe(Client client, UnsubscribeMessage message)

Methods inherited from class java.lang.Object

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

Constructor Detail

MockBrokerHandler

public MockBrokerHandler()

Method Detail

connect

public boolean connect(Client client,
                       ConnectMessage message)
                throws Exception

Throws:

Exception

See Also:

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

publish

public boolean publish(Client client,
                       PubMessage message)
                throws Exception

Throws:

Exception

See Also:

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

pubAck

public boolean pubAck(Client client,
                      PubAckMessage message)
               throws Exception

Throws:

Exception

See Also:

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

pubRec

public boolean pubRec(Client client,
                      PubRecMessage message)
               throws Exception

Throws:

Exception

See Also:

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

pubRel

public boolean pubRel(Client client,
                      PubRelMessage message)
               throws Exception

Throws:

Exception

See Also:

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

pubComp

public boolean pubComp(Client client,
                       PubCompMessage message)
                throws Exception

Throws:

Exception

See Also:

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

subscribe

public boolean subscribe(Client client,
                         SubscribeMessage message)
                  throws Exception

Throws:

Exception

See Also:

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

unsubscribe

public boolean unsubscribe(Client client,
                           UnsubscribeMessage message)
                    throws Exception

Throws:

Exception

See Also:

MessageHandler.unsubscribe(net.sf.xenqtt.message.MqttChannel, net.sf.xenqtt.message.UnsubscribeMessage)

disconnect

public void disconnect(Client client,
                       DisconnectMessage message)
                throws Exception

Throws:

Exception

See Also:

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

channelOpened

public void channelOpened(Client client)

See Also:

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

channelClosed

public void channelClosed(Client client,
                          Throwable cause)

See Also:

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

unexpectedMessage

public void unexpectedMessage(Client client,
                              MqttMessage message)

Called when an unexpected message is received. This includes things like receiving an UnsubAckMessage which should never be received by a broker or receiving any message other than ConnectMessage as the first message from a client.