ptserver.communication

Class TokenListener

java.lang.Object

ptserver.communication.TokenListener

All Implemented Interfaces:

com.ibm.mqtt.MqttSimpleCallback

public class TokenListener
extends java.lang.Object
implements com.ibm.mqtt.MqttSimpleCallback

TokenListener is responsible for processing MQTT messages received, converting back to tokens and putting those tokens into appropriate queues.

Since:

Ptolemy II 10.0

Version:

$Id$

Author:

Anar Huseynov

Pt.AcceptedRating:

Red (ahuseyno)

Pt.ProposedRating:

Red (ahuseyno)

Constructor Summary

Constructors

Constructor and Description
TokenListener(ProxyModelInfrastructure proxyModelInfrastructure) Initialize the instance by reading needed fields from the remoteModel.

Method Summary

Modifier and Type	Method and Description
void	connectionLost() Callback method when the connection with the broker is lost.
void	publishArrived(java.lang.String topicName, byte[] payload, int qos, boolean retained) Callback method when a message from the topic is received.

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenListener

public TokenListener(ProxyModelInfrastructure proxyModelInfrastructure)

Initialize the instance by reading needed fields from the remoteModel.

Parameters:

proxyModelInfrastructure - The infrastructure that created this listener and controls the state of the execution.

Method Detail

connectionLost

public void connectionLost()
                    throws java.lang.Exception

Callback method when the connection with the broker is lost.

Specified by:

connectionLost in interface com.ibm.mqtt.MqttSimpleCallback

Throws:

java.lang.Exception - If the connection was lost.

See Also:

MqttSimpleCallback.connectionLost()

publishArrived

public void publishArrived(java.lang.String topicName,
                           byte[] payload,
                           int qos,
                           boolean retained)
                    throws java.lang.Exception

Callback method when a message from the topic is received.

Specified by:

publishArrived in interface com.ibm.mqtt.MqttSimpleCallback

Parameters:

topicName - The name of the topic from which the message was received.

payload - The MQTT message.

qos - The Quality of Service at which the message was delivered by the broker.

retained - indicates if this message is retained by the broker.

Throws:

java.lang.Exception - if there is a problem reading next token or setting attribute value

See Also:

MqttSimpleCallback.publishArrived(java.lang.String, byte[], int, boolean)