public class PahoMqttContext
extends java.lang.Object
implements ej.data.pubsub.MqttContext
MqttContext
that uses Paho.Modifier and Type | Field and Description |
---|---|
protected ej.data.pubsub.MqttListener |
listener
The
MqttListener called when data is received. |
Constructor and Description |
---|
PahoMqttContext(PahoMqttAgent mqttAgent) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.lang.String |
getLocalTopicPrefix() |
java.lang.String |
getSharedTopicPrefix() |
ej.data.DataWriter |
newPublication(java.lang.String topic) |
ej.data.DataWriter |
newPublication(java.lang.String topic,
int qos,
boolean retain) |
void |
setListener(ej.data.pubsub.MqttListener listener) |
void |
subscribe(java.lang.String topicFilter) |
void |
subscribe(java.lang.String topicFilter,
int qos) |
void |
unsubscribe(java.lang.String topicFilter) |
protected ej.data.pubsub.MqttListener listener
MqttListener
called when data is received. May be null.public PahoMqttContext(PahoMqttAgent mqttAgent)
public void close() throws java.io.IOException
close
in interface ej.data.pubsub.MqttContext
close
in interface java.lang.AutoCloseable
java.io.IOException
public ej.data.DataWriter newPublication(java.lang.String topic) throws java.io.IOException
newPublication
in interface ej.data.pubsub.MqttContext
java.io.IOException
public ej.data.DataWriter newPublication(java.lang.String topic, int qos, boolean retain) throws java.io.IOException
newPublication
in interface ej.data.pubsub.MqttContext
java.io.IOException
public void setListener(ej.data.pubsub.MqttListener listener)
setListener
in interface ej.data.pubsub.MqttContext
public void subscribe(java.lang.String topicFilter) throws java.io.IOException
subscribe
in interface ej.data.pubsub.MqttContext
java.io.IOException
public void subscribe(java.lang.String topicFilter, int qos) throws java.io.IOException
subscribe
in interface ej.data.pubsub.MqttContext
java.io.IOException
public void unsubscribe(java.lang.String topicFilter) throws java.io.IOException
unsubscribe
in interface ej.data.pubsub.MqttContext
java.io.IOException
public java.lang.String getSharedTopicPrefix()
getSharedTopicPrefix
in interface ej.data.pubsub.MqttContext
public java.lang.String getLocalTopicPrefix()
getLocalTopicPrefix
in interface ej.data.pubsub.MqttContext