Package | Description |
---|---|
com.amazonaws.services.iot.client | |
com.amazonaws.services.iot.client.core | |
com.amazonaws.services.iot.client.mqtt | |
com.amazonaws.services.iot.client.shadow |
Modifier and Type | Class and Description |
---|---|
class |
AWSIotTopic
This class is used for subscribing to a topic in the subscription APIs, such
as
AWSIotMqttClient.subscribe(AWSIotTopic topic) . |
Modifier and Type | Method and Description |
---|---|
AWSIotMessage |
AWSIotMqttClient.getWillMessage()
Gets the Last Will and Testament message currently configured.
|
Modifier and Type | Method and Description |
---|---|
void |
AWSIotDevice.delete(AWSIotMessage message,
long timeout)
Deletes the content of a thing shadow.
|
void |
AWSIotDevice.get(AWSIotMessage message,
long timeout)
Retrieves the latest state stored in the thing shadow.
|
void |
AWSIotTopic.onMessage(AWSIotMessage message)
Callback function to be invoked upon the arrival of a subscribed message.
|
void |
AWSIotMqttClient.publish(AWSIotMessage message)
Publishes the payload to a given topic.
|
void |
AWSIotMqttClient.publish(AWSIotMessage message,
long timeout)
Publishes the payload to a given topic.
|
void |
AWSIotMqttClient.setWillMessage(AWSIotMessage willMessage)
Sets a new Last Will and Testament message.
|
void |
AWSIotDevice.update(AWSIotMessage message,
long timeout)
Updates the content of a thing shadow with the data provided in the
request.
|
Modifier and Type | Class and Description |
---|---|
class |
AwsIotCompletion
This is a helper class that can be used to manage the request execution and
return either synchronously or asynchronously the result, e.g.
|
Modifier and Type | Field and Description |
---|---|
protected AWSIotMessage |
AwsIotCompletion.request
The request containing the callback functions.
|
protected AWSIotMessage |
AbstractAwsIotClient.willMessage |
Modifier and Type | Method and Description |
---|---|
AWSIotMessage |
AbstractAwsIotClient.getWillMessage() |
Modifier and Type | Method and Description |
---|---|
ConcurrentLinkedQueue<AWSIotMessage> |
AwsIotConnection.getPublishQueue()
The offline publish queue holding messages while the connection is being
established.
|
ConcurrentLinkedQueue<AWSIotMessage> |
AwsIotConnection.getSubscribeQueue()
The offline subscribe request queue holding messages while the connection
is being established.
|
ConcurrentLinkedQueue<AWSIotMessage> |
AwsIotConnection.getUnsubscribeQueue()
The offline unsubscribe request queue holding messages while the
connection is being established.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractAwsIotClient.dispatch(AWSIotMessage message) |
void |
AwsIotTopicCallback.onMessage(AWSIotMessage message) |
void |
AwsIotConnection.publish(AWSIotMessage message)
The actual publish method exposed by this class.
|
void |
AbstractAwsIotClient.publish(AWSIotMessage message) |
void |
AbstractAwsIotClient.publish(AWSIotMessage message,
long timeout) |
protected abstract void |
AwsIotConnection.publishMessage(AWSIotMessage message)
Abstract method which is called to publish a message.
|
void |
AbstractAwsIotClient.setWillMessage(AWSIotMessage willMessage) |
void |
AwsIotConnection.subscribe(AWSIotMessage message)
The actual subscribe method exposed by this class.
|
protected abstract void |
AwsIotConnection.subscribeTopic(AWSIotMessage message)
Abstract method which is called to subscribe to a topic.
|
void |
AwsIotConnection.unsubscribe(AWSIotMessage message)
The actual unsubscribe method exposed by this class.
|
protected abstract void |
AwsIotConnection.unsubscribeTopic(AWSIotMessage message)
Abstract method which is called to unsubscribe to a topic.
|
Constructor and Description |
---|
AwsIotCompletion(AWSIotMessage req,
long timeout,
boolean isAsync)
Instantiates a new completion object either synchronous or asynchronous
request based on the
isAsync argument. |
Modifier and Type | Method and Description |
---|---|
void |
AwsIotMqttConnection.publishMessage(AWSIotMessage message) |
void |
AwsIotMqttConnection.subscribeTopic(AWSIotMessage message) |
void |
AwsIotMqttConnection.unsubscribeTopic(AWSIotMessage message) |
Modifier and Type | Class and Description |
---|---|
class |
AwsIotDeviceCommand
This is a helper class that can be used to manage the execution result of a
shadow command, i.e.
|
class |
AwsIotDeviceCommandAckListener
This class extends
AWSIotTopic to provide customized callback
functions for the subscription requests of the shadow commands. |
class |
AwsIotDeviceDeltaListener
This class extends
AWSIotTopic to provide a callback function for
receiving the shadow delta updates. |
class |
AwsIotDeviceReportMessage |
class |
AwsIotDeviceSyncMessage |
Modifier and Type | Method and Description |
---|---|
AWSIotMessage |
AwsIotDeviceCommand.getResponse() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractAwsIotDevice.delete(AWSIotMessage message,
long timeout) |
protected void |
AbstractAwsIotDevice.get(AWSIotMessage message,
long timeout) |
void |
AbstractAwsIotDevice.onCommandAck(AWSIotMessage message) |
void |
AwsIotDeviceCommandManager.onCommandAck(AWSIotMessage response) |
void |
AwsIotDeviceCommandAckListener.onMessage(AWSIotMessage message) |
void |
AwsIotDeviceDeltaListener.onMessage(AWSIotMessage message) |
String |
AwsIotDeviceCommandManager.runCommand(AwsIotDeviceCommandManager.Command command,
AWSIotMessage request,
long commandTimeout) |
String |
AwsIotDeviceCommandManager.runCommand(AwsIotDeviceCommandManager.Command command,
AWSIotMessage request,
long commandTimeout,
boolean isAsync) |
String |
AwsIotDeviceCommandManager.runCommandSync(AwsIotDeviceCommandManager.Command command,
AWSIotMessage request) |
String |
AwsIotDeviceCommandManager.runCommandSync(AwsIotDeviceCommandManager.Command command,
AWSIotMessage request,
long commandTimeout) |
void |
AwsIotDeviceCommand.setResponse(AWSIotMessage response) |
protected void |
AbstractAwsIotDevice.update(AWSIotMessage message,
long timeout) |
Constructor and Description |
---|
AwsIotDeviceCommand(AwsIotDeviceCommandManager commandManager,
AwsIotDeviceCommandManager.Command command,
String commandId,
AWSIotMessage request,
long commandTimeout,
boolean isAsync) |
Copyright © 2020. All rights reserved.