Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.Set<PahoMqttContext>> |
PahoMqttAgent.subscribedTopics
Gives for each subscribed topic, the set of
PahoMqttContext that have subscribed to it. |
Modifier and Type | Method and Description |
---|---|
java.util.Set<PahoMqttContext> |
PahoMqttAgent.getMqttContextSubscribedTo(java.lang.String topic)
Returns the
MqttContext that are subscribed to the given topic. |
Modifier and Type | Method and Description |
---|---|
void |
PahoMqttAgent.cleanupConnection(PahoMqttContext connection)
Free any data related to the given connection
|
void |
MqttAgentConfiguration.errorOnMessageReceivedCallback(java.lang.Throwable t,
PahoMqttContext context,
java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage message)
Method called when an error occurs while calling a listener
MqttListener.messageReceived(String, DataReader) . |
void |
PahoMqttAgent.subscribe(PahoMqttContext connection,
java.lang.String topicFilter,
int qos)
Subscribe the given connection to the given topic.
|
void |
PahoMqttAgent.unsubscribe(PahoMqttContext connection,
java.lang.String topicFilter)
Remove subscription for the given connection.
|