class MqttTokenAndroid
extends java.lang.Object
implements org.eclipse.paho.client.mqttv3.IMqttToken
Implementation of the IMqttToken interface for use from within the MqttAndroidClient implementation
| Constructor and Description |
|---|
MqttTokenAndroid(MqttAndroidClient client,
java.lang.Object userContext,
org.eclipse.paho.client.mqttv3.IMqttActionListener listener)
Standard constructor
|
MqttTokenAndroid(MqttAndroidClient client,
java.lang.Object userContext,
org.eclipse.paho.client.mqttv3.IMqttActionListener listener,
java.lang.String[] topics)
Constructor for use with subscribe operations
|
| Modifier and Type | Method and Description |
|---|---|
org.eclipse.paho.client.mqttv3.IMqttActionListener |
getActionCallback() |
org.eclipse.paho.client.mqttv3.IMqttAsyncClient |
getClient() |
org.eclipse.paho.client.mqttv3.MqttException |
getException() |
int |
getMessageId() |
java.lang.String[] |
getTopics() |
java.lang.Object |
getUserContext() |
boolean |
isComplete() |
(package private) void |
notifyComplete()
notify successful completion of the operation
|
(package private) void |
notifyFailure(java.lang.Throwable exception)
notify unsuccessful completion of the operation
|
void |
setActionCallback(org.eclipse.paho.client.mqttv3.IMqttActionListener listener) |
(package private) void |
setComplete(boolean complete) |
(package private) void |
setDelegate(org.eclipse.paho.client.mqttv3.IMqttToken delegate) |
(package private) void |
setException(org.eclipse.paho.client.mqttv3.MqttException exception) |
void |
setUserContext(java.lang.Object userContext) |
void |
waitForCompletion() |
void |
waitForCompletion(long timeout) |
MqttTokenAndroid(MqttAndroidClient client, java.lang.Object userContext, org.eclipse.paho.client.mqttv3.IMqttActionListener listener)
client - used to pass MqttAndroidClient objectuserContext - used to pass contextlistener - optional listener that will be notified when the action completes. Use null if not required.MqttTokenAndroid(MqttAndroidClient client, java.lang.Object userContext, org.eclipse.paho.client.mqttv3.IMqttActionListener listener, java.lang.String[] topics)
client - used to pass MqttAndroidClient objectuserContext - used to pass contextlistener - optional listener that will be notified when the action completes. Use null if not required.topics - topics to subscribe to, which can include wildcards.public void waitForCompletion()
throws org.eclipse.paho.client.mqttv3.MqttException,
org.eclipse.paho.client.mqttv3.MqttSecurityException
waitForCompletion in interface org.eclipse.paho.client.mqttv3.IMqttTokenorg.eclipse.paho.client.mqttv3.MqttExceptionorg.eclipse.paho.client.mqttv3.MqttSecurityExceptionIMqttToken.waitForCompletion()public void waitForCompletion(long timeout)
throws org.eclipse.paho.client.mqttv3.MqttException,
org.eclipse.paho.client.mqttv3.MqttSecurityException
waitForCompletion in interface org.eclipse.paho.client.mqttv3.IMqttTokenorg.eclipse.paho.client.mqttv3.MqttExceptionorg.eclipse.paho.client.mqttv3.MqttSecurityExceptionIMqttToken.waitForCompletion(long)void notifyComplete()
void notifyFailure(java.lang.Throwable exception)
public boolean isComplete()
isComplete in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.isComplete()void setComplete(boolean complete)
public org.eclipse.paho.client.mqttv3.MqttException getException()
getException in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.getException()void setException(org.eclipse.paho.client.mqttv3.MqttException exception)
public org.eclipse.paho.client.mqttv3.IMqttAsyncClient getClient()
getClient in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.getClient()public void setActionCallback(org.eclipse.paho.client.mqttv3.IMqttActionListener listener)
setActionCallback in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.setActionCallback(IMqttActionListener)public org.eclipse.paho.client.mqttv3.IMqttActionListener getActionCallback()
getActionCallback in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.getActionCallback()public java.lang.String[] getTopics()
getTopics in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.getTopics()public void setUserContext(java.lang.Object userContext)
setUserContext in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.setUserContext(Object)public java.lang.Object getUserContext()
getUserContext in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.getUserContext()void setDelegate(org.eclipse.paho.client.mqttv3.IMqttToken delegate)
public int getMessageId()
getMessageId in interface org.eclipse.paho.client.mqttv3.IMqttTokenIMqttToken.getMessageId()