com.amazonaws.services.iot.client.shadow

Class AwsIotDeviceCommandManager

java.lang.Object

com.amazonaws.services.iot.client.shadow.AwsIotDeviceCommandManager

public class AwsIotDeviceCommandManager
extends Object

This class manages the commands sent to the shadow. It maintains a list of pending commands that are yet to be accepted or rejected by the shadow. Upon receiving the shadow response for a command, it will notify therefore resume the execution of the caller.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AwsIotDeviceCommandManager.Command
static class	AwsIotDeviceCommandManager.CommandAck

Constructor Summary

Constructors

Constructor and Description
AwsIotDeviceCommandManager(AbstractAwsIotDevice device)

Method Summary

Modifier and Type	Method and Description
AbstractAwsIotDevice	getDevice()
com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()
ConcurrentMap<String,AwsIotDeviceCommand>	getPendingCommands()
String	getTopic(AwsIotDeviceCommandManager.Command command, AwsIotDeviceCommandManager.CommandAck ack)
boolean	isDeltaTopic(String topic)
void	onCommandAck(AWSIotMessage response)
void	onCommandTimeout(AwsIotDeviceCommand command)
void	onDeactivate()
void	onSubscriptionAck(String topic, boolean success)
String	runCommand(AwsIotDeviceCommandManager.Command command, AWSIotMessage request, long commandTimeout)
String	runCommand(AwsIotDeviceCommandManager.Command command, AWSIotMessage request, long commandTimeout, boolean isAsync)
String	runCommandSync(AwsIotDeviceCommandManager.Command command, AWSIotMessage request)
String	runCommandSync(AwsIotDeviceCommandManager.Command command, AWSIotMessage request, long commandTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

AwsIotDeviceCommandManager

public AwsIotDeviceCommandManager(AbstractAwsIotDevice device)

Method Detail

getTopic

public String getTopic(AwsIotDeviceCommandManager.Command command,
                       AwsIotDeviceCommandManager.CommandAck ack)

runCommandSync

public String runCommandSync(AwsIotDeviceCommandManager.Command command,
                             AWSIotMessage request)
                      throws AWSIotException

Throws:

AWSIotException

runCommandSync

public String runCommandSync(AwsIotDeviceCommandManager.Command command,
                             AWSIotMessage request,
                             long commandTimeout)
                      throws AWSIotException,
                             AWSIotTimeoutException

Throws:

AWSIotException

AWSIotTimeoutException

runCommand

public String runCommand(AwsIotDeviceCommandManager.Command command,
                         AWSIotMessage request,
                         long commandTimeout)
                  throws AWSIotException

Throws:

AWSIotException

runCommand

public String runCommand(AwsIotDeviceCommandManager.Command command,
                         AWSIotMessage request,
                         long commandTimeout,
                         boolean isAsync)
                  throws AWSIotException,
                         AWSIotTimeoutException

Throws:

AWSIotException

AWSIotTimeoutException

onCommandAck

public void onCommandAck(AWSIotMessage response)

onCommandTimeout

public void onCommandTimeout(AwsIotDeviceCommand command)

onSubscriptionAck

public void onSubscriptionAck(String topic,
                              boolean success)

onDeactivate

public void onDeactivate()

isDeltaTopic

public boolean isDeltaTopic(String topic)

getPendingCommands

public ConcurrentMap<String,AwsIotDeviceCommand> getPendingCommands()

getDevice

public AbstractAwsIotDevice getDevice()

getObjectMapper

public com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()