Class MQTTConnection

java.lang.Object

com.swiftmq.impl.mqtt.connection.MQTTConnection

All Implemented Interfaces:

MQTTVisitor, AssociateSessionCallback, MqttListener, com.swiftmq.swiftlet.timer.event.TimerListener, com.swiftmq.tools.pipeline.POVisitor, EventListener

public class MQTTConnection
extends Object
implements com.swiftmq.swiftlet.timer.event.TimerListener, MqttListener, AssociateSessionCallback, MQTTVisitor

Constructor Summary

Constructors

Constructor	Description
MQTTConnection(SwiftletContext ctx, com.swiftmq.swiftlet.net.Connection connection, com.swiftmq.mgmt.Entity usage, com.swiftmq.mgmt.Entity connectionTemplate)

Method Summary

Modifier and Type	Method	Description
void	associated(MQTTSession session)
void	close()
void	collect(long lastCollect)
void	dispatch(com.swiftmq.tools.pipeline.POObject event)
com.swiftmq.swiftlet.auth.ActiveLogin	getActiveLogin()
String	getClientId()
com.swiftmq.swiftlet.net.Connection	getConnection()
com.swiftmq.mgmt.Entity	getConnectionTemplate()
MQTTConnection	getMqttConnection()
OutboundQueue	getOutboundQueue()
String	getRemoteHostname()
com.swiftmq.mgmt.Entity	getUsage()
void	initiateClose(String reason)
String	nextId()
void	onException(Exception e)
void	onMessage(List<MqttMessage> list)
void	performTimeAction()
String	toString()
void	visit(POClose po)
void	visit(POCollect po)
void	visit(POConnect po)
void	visit(PODisconnect po)
void	visit(POPingReq po)
void	visit(POProtocolError po)
void	visit(POPubAck po)
void	visit(POPubComp po)
void	visit(POPublish po)
void	visit(POPubRec po)
void	visit(POPubRel po)
void	visit(POSendMessage po)
void	visit(POSessionAssociated po)
void	visit(POSubscribe po)
void	visit(POUnsubscribe po)

Methods inherited from class Object

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

Constructor Details

MQTTConnection

public MQTTConnection(SwiftletContext ctx,
 com.swiftmq.swiftlet.net.Connection connection,
 com.swiftmq.mgmt.Entity usage,
 com.swiftmq.mgmt.Entity connectionTemplate)

Method Details

getClientId

public String getClientId()

getUsage

public com.swiftmq.mgmt.Entity getUsage()

getConnectionTemplate

public com.swiftmq.mgmt.Entity getConnectionTemplate()

getConnection

public com.swiftmq.swiftlet.net.Connection getConnection()

getActiveLogin

public com.swiftmq.swiftlet.auth.ActiveLogin getActiveLogin()

getRemoteHostname

public String getRemoteHostname()

getOutboundQueue

public OutboundQueue getOutboundQueue()

nextId

public String nextId()

collect

public void collect(long lastCollect)

getMqttConnection

public MQTTConnection getMqttConnection()

Specified by:

getMqttConnection in interface AssociateSessionCallback

associated

public void associated(MQTTSession session)

Specified by:

associated in interface AssociateSessionCallback

performTimeAction

public void performTimeAction()

Specified by:

performTimeAction in interface com.swiftmq.swiftlet.timer.event.TimerListener

dispatch

public void dispatch(com.swiftmq.tools.pipeline.POObject event)

initiateClose

public void initiateClose(String reason)

onMessage

public void onMessage(List<MqttMessage> list)

Specified by:

onMessage in interface MqttListener

onException

public void onException(Exception e)

Specified by:

onException in interface MqttListener

close

public void close()

visit

public void visit(POConnect po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POSessionAssociated po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POPublish po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POSendMessage po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POPubAck po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POPubRec po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POPubRel po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POPubComp po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POSubscribe po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POUnsubscribe po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POPingReq po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(PODisconnect po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POProtocolError po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POCollect po)

Specified by:

visit in interface MQTTVisitor

visit

public void visit(POClose po)

Specified by:

visit in interface MQTTVisitor

toString

public String toString()

Overrides:

toString in class Object