AWS IoT C++ SDK
|
Define a class for ConnectActionAsync. More...
#include <Connect.hpp>
Public Member Functions | |
ConnectActionAsync (const ConnectActionAsync &)=delete | |
ConnectActionAsync (ConnectActionAsync &&)=delete | |
ConnectActionAsync & | operator= (const ConnectActionAsync &) &=delete |
ConnectActionAsync & | operator= (ConnectActionAsync &&) &=delete |
ConnectActionAsync (std::shared_ptr< ClientState > p_client_state) | |
Constructor. More... | |
ResponseCode | PerformAction (std::shared_ptr< NetworkConnection > p_network_connection, std::shared_ptr< ActionData > p_action_data) |
Perform MQTT Connect Action in Async mode. More... | |
![]() | |
ActionType | GetActionType () |
Get Type of this Action. More... | |
util::String | GetActionInfo () |
Get information/description about the current action. More... | |
void | SetParentThreadSync (std::shared_ptr< std::atomic_bool > p_thread_continue) |
Sets the parent thread sync variable. More... | |
virtual ResponseCode | PerformAction (std::shared_ptr< NetworkConnection > p_network_connection, std::shared_ptr< ActionData > p_action_data)=0 |
Virtual base function for Performing Action. More... | |
Action (const Action &)=delete | |
Action (Action &&)=delete | |
Action & | operator= (const Action &) &=delete |
Action & | operator= (Action &&) &=delete |
Action (ActionType action_type, util::String action_info_string) | |
Action Constructor. More... | |
Static Public Member Functions | |
static std::unique_ptr< Action > | Create (std::shared_ptr< ActionState > p_action_state) |
Factory Create method. More... | |
Protected Attributes | |
std::shared_ptr< ClientState > | p_client_state_ |
Shared Client State instance. | |
![]() | |
ActionType | action_type_ |
Type of the action. | |
util::String | action_info_string_ |
Info string. | |
std::shared_ptr< std::atomic_bool > | p_thread_continue_ |
Shared atomic variable used for sync when action is run in separate thread. | |
Additional Inherited Members | |
![]() | |
typedef std::function< std::unique_ptr< Action >(std::shared_ptr< ActionState > p_action_state)> | CreateHandlerPtr |
![]() | |
ResponseCode | ReadFromNetworkBuffer (std::shared_ptr< NetworkConnection > p_network_connection, util::Vector< unsigned char > &read_buf, size_t bytes_to_read) |
Generic Network Read function for all actions. More... | |
ResponseCode | WriteToNetworkBuffer (std::shared_ptr< NetworkConnection > p_network_connection, const util::String &write_buf) |
Generic Network Write function for all actions. More... | |
This class defines an Asynchronous action for performing a MQTT Connect operation
awsiotsdk::mqtt::ConnectActionAsync::ConnectActionAsync | ( | std::shared_ptr< ClientState > | p_client_state | ) |
p_client_state | - Shared Client State instance |
|
static |
p_client_state | - Shared Client State instance |
|
virtual |
Performs the MQTT Connect Operation in Async mode. This also calls Connect on the Network Connection provided with the Perform Action call. If the Network connect call fails, the action will return with the ResponseCode returned by the Network Connect call. This does not wait for CONNACK to be received. CONNACK is handled separately in the HandleConnack function of NetworkReadAction. If the MQTT connection is already active, will not attempt another Connect and return with appropriate ResponseCode.
p_network_connection | - Network connection instance to use for performing this action |
p_action_data | - Action data specific to this execution of the Action |
Implements awsiotsdk::Action.