Package software.amazon.awssdk.aws.greengrass

Class GreengrassCoreIPCClientV2

java.lang.Object

software.amazon.awssdk.aws.greengrass.GreengrassCoreIPCClientV2

All Implemented Interfaces:

AutoCloseable

public class GreengrassCoreIPCClientV2
extends Object
implements AutoCloseable

V2 Client for Greengrass.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GreengrassCoreIPCClientV2.Builder
static class	GreengrassCoreIPCClientV2.StreamingResponse<T,U>

Method Summary

Modifier and Type	Method	Description
AuthorizeClientDeviceActionResponse	authorizeClientDeviceAction(AuthorizeClientDeviceActionRequest request)	Perform the authorizeClientDeviceAction operation synchronously.
CompletableFuture<AuthorizeClientDeviceActionResponse>	authorizeClientDeviceActionAsync(AuthorizeClientDeviceActionRequest request)	Perform the authorizeClientDeviceAction operation asynchronously.
static GreengrassCoreIPCClientV2.Builder	builder()
CancelLocalDeploymentResponse	cancelLocalDeployment(CancelLocalDeploymentRequest request)	Perform the cancelLocalDeployment operation synchronously.
CompletableFuture<CancelLocalDeploymentResponse>	cancelLocalDeploymentAsync(CancelLocalDeploymentRequest request)	Perform the cancelLocalDeployment operation asynchronously.
void	close()
CreateDebugPasswordResponse	createDebugPassword(CreateDebugPasswordRequest request)	Perform the createDebugPassword operation synchronously.
CompletableFuture<CreateDebugPasswordResponse>	createDebugPasswordAsync(CreateDebugPasswordRequest request)	Perform the createDebugPassword operation asynchronously.
CreateLocalDeploymentResponse	createLocalDeployment(CreateLocalDeploymentRequest request)	Perform the createLocalDeployment operation synchronously.
CompletableFuture<CreateLocalDeploymentResponse>	createLocalDeploymentAsync(CreateLocalDeploymentRequest request)	Perform the createLocalDeployment operation asynchronously.
DeferComponentUpdateResponse	deferComponentUpdate(DeferComponentUpdateRequest request)	Perform the deferComponentUpdate operation synchronously.
CompletableFuture<DeferComponentUpdateResponse>	deferComponentUpdateAsync(DeferComponentUpdateRequest request)	Perform the deferComponentUpdate operation asynchronously.
DeleteThingShadowResponse	deleteThingShadow(DeleteThingShadowRequest request)	Perform the deleteThingShadow operation synchronously.
CompletableFuture<DeleteThingShadowResponse>	deleteThingShadowAsync(DeleteThingShadowRequest request)	Perform the deleteThingShadow operation asynchronously.
GreengrassCoreIPC	getClient()
GetClientDeviceAuthTokenResponse	getClientDeviceAuthToken(GetClientDeviceAuthTokenRequest request)	Perform the getClientDeviceAuthToken operation synchronously.
CompletableFuture<GetClientDeviceAuthTokenResponse>	getClientDeviceAuthTokenAsync(GetClientDeviceAuthTokenRequest request)	Perform the getClientDeviceAuthToken operation asynchronously.
GetComponentDetailsResponse	getComponentDetails(GetComponentDetailsRequest request)	Perform the getComponentDetails operation synchronously.
CompletableFuture<GetComponentDetailsResponse>	getComponentDetailsAsync(GetComponentDetailsRequest request)	Perform the getComponentDetails operation asynchronously.
GetConfigurationResponse	getConfiguration(GetConfigurationRequest request)	Perform the getConfiguration operation synchronously.
CompletableFuture<GetConfigurationResponse>	getConfigurationAsync(GetConfigurationRequest request)	Perform the getConfiguration operation asynchronously.
GetLocalDeploymentStatusResponse	getLocalDeploymentStatus(GetLocalDeploymentStatusRequest request)	Perform the getLocalDeploymentStatus operation synchronously.
CompletableFuture<GetLocalDeploymentStatusResponse>	getLocalDeploymentStatusAsync(GetLocalDeploymentStatusRequest request)	Perform the getLocalDeploymentStatus operation asynchronously.
GetSecretValueResponse	getSecretValue(GetSecretValueRequest request)	Perform the getSecretValue operation synchronously.
CompletableFuture<GetSecretValueResponse>	getSecretValueAsync(GetSecretValueRequest request)	Perform the getSecretValue operation asynchronously.
GetThingShadowResponse	getThingShadow(GetThingShadowRequest request)	Perform the getThingShadow operation synchronously.
CompletableFuture<GetThingShadowResponse>	getThingShadowAsync(GetThingShadowRequest request)	Perform the getThingShadow operation asynchronously.
ListComponentsResponse	listComponents(ListComponentsRequest request)	Perform the listComponents operation synchronously.
CompletableFuture<ListComponentsResponse>	listComponentsAsync(ListComponentsRequest request)	Perform the listComponents operation asynchronously.
ListLocalDeploymentsResponse	listLocalDeployments(ListLocalDeploymentsRequest request)	Perform the listLocalDeployments operation synchronously.
CompletableFuture<ListLocalDeploymentsResponse>	listLocalDeploymentsAsync(ListLocalDeploymentsRequest request)	Perform the listLocalDeployments operation asynchronously.
ListNamedShadowsForThingResponse	listNamedShadowsForThing(ListNamedShadowsForThingRequest request)	Perform the listNamedShadowsForThing operation synchronously.
CompletableFuture<ListNamedShadowsForThingResponse>	listNamedShadowsForThingAsync(ListNamedShadowsForThingRequest request)	Perform the listNamedShadowsForThing operation asynchronously.
PauseComponentResponse	pauseComponent(PauseComponentRequest request)	Perform the pauseComponent operation synchronously.
CompletableFuture<PauseComponentResponse>	pauseComponentAsync(PauseComponentRequest request)	Perform the pauseComponent operation asynchronously.
PublishToIoTCoreResponse	publishToIoTCore(PublishToIoTCoreRequest request)	Perform the publishToIoTCore operation synchronously.
CompletableFuture<PublishToIoTCoreResponse>	publishToIoTCoreAsync(PublishToIoTCoreRequest request)	Perform the publishToIoTCore operation asynchronously.
PublishToTopicResponse	publishToTopic(PublishToTopicRequest request)	Perform the publishToTopic operation synchronously.
CompletableFuture<PublishToTopicResponse>	publishToTopicAsync(PublishToTopicRequest request)	Perform the publishToTopic operation asynchronously.
PutComponentMetricResponse	putComponentMetric(PutComponentMetricRequest request)	Perform the putComponentMetric operation synchronously.
CompletableFuture<PutComponentMetricResponse>	putComponentMetricAsync(PutComponentMetricRequest request)	Perform the putComponentMetric operation asynchronously.
RestartComponentResponse	restartComponent(RestartComponentRequest request)	Perform the restartComponent operation synchronously.
CompletableFuture<RestartComponentResponse>	restartComponentAsync(RestartComponentRequest request)	Perform the restartComponent operation asynchronously.
ResumeComponentResponse	resumeComponent(ResumeComponentRequest request)	Perform the resumeComponent operation synchronously.
CompletableFuture<ResumeComponentResponse>	resumeComponentAsync(ResumeComponentRequest request)	Perform the resumeComponent operation asynchronously.
SendConfigurationValidityReportResponse	sendConfigurationValidityReport(SendConfigurationValidityReportRequest request)	Perform the sendConfigurationValidityReport operation synchronously.
CompletableFuture<SendConfigurationValidityReportResponse>	sendConfigurationValidityReportAsync(SendConfigurationValidityReportRequest request)	Perform the sendConfigurationValidityReport operation asynchronously.
StopComponentResponse	stopComponent(StopComponentRequest request)	Perform the stopComponent operation synchronously.
CompletableFuture<StopComponentResponse>	stopComponentAsync(StopComponentRequest request)	Perform the stopComponent operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToCertificateUpdatesResponse,SubscribeToCertificateUpdatesResponseHandler>	subscribeToCertificateUpdates(SubscribeToCertificateUpdatesRequest request, Consumer<CertificateUpdateEvent> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToCertificateUpdates operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToCertificateUpdatesResponse,SubscribeToCertificateUpdatesResponseHandler>	subscribeToCertificateUpdates(SubscribeToCertificateUpdatesRequest request, StreamResponseHandler<CertificateUpdateEvent> streamResponseHandler)	Perform the subscribeToCertificateUpdates operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToCertificateUpdatesResponse>,SubscribeToCertificateUpdatesResponseHandler>	subscribeToCertificateUpdatesAsync(SubscribeToCertificateUpdatesRequest request, Consumer<CertificateUpdateEvent> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToCertificateUpdates operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToCertificateUpdatesResponse>,SubscribeToCertificateUpdatesResponseHandler>	subscribeToCertificateUpdatesAsync(SubscribeToCertificateUpdatesRequest request, StreamResponseHandler<CertificateUpdateEvent> streamResponseHandler)	Perform the subscribeToCertificateUpdates operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToComponentUpdatesResponse,SubscribeToComponentUpdatesResponseHandler>	subscribeToComponentUpdates(SubscribeToComponentUpdatesRequest request, Consumer<ComponentUpdatePolicyEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToComponentUpdates operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToComponentUpdatesResponse,SubscribeToComponentUpdatesResponseHandler>	subscribeToComponentUpdates(SubscribeToComponentUpdatesRequest request, StreamResponseHandler<ComponentUpdatePolicyEvents> streamResponseHandler)	Perform the subscribeToComponentUpdates operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToComponentUpdatesResponse>,SubscribeToComponentUpdatesResponseHandler>	subscribeToComponentUpdatesAsync(SubscribeToComponentUpdatesRequest request, Consumer<ComponentUpdatePolicyEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToComponentUpdates operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToComponentUpdatesResponse>,SubscribeToComponentUpdatesResponseHandler>	subscribeToComponentUpdatesAsync(SubscribeToComponentUpdatesRequest request, StreamResponseHandler<ComponentUpdatePolicyEvents> streamResponseHandler)	Perform the subscribeToComponentUpdates operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToConfigurationUpdateResponse,SubscribeToConfigurationUpdateResponseHandler>	subscribeToConfigurationUpdate(SubscribeToConfigurationUpdateRequest request, Consumer<ConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToConfigurationUpdate operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToConfigurationUpdateResponse,SubscribeToConfigurationUpdateResponseHandler>	subscribeToConfigurationUpdate(SubscribeToConfigurationUpdateRequest request, StreamResponseHandler<ConfigurationUpdateEvents> streamResponseHandler)	Perform the subscribeToConfigurationUpdate operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToConfigurationUpdateResponse>,SubscribeToConfigurationUpdateResponseHandler>	subscribeToConfigurationUpdateAsync(SubscribeToConfigurationUpdateRequest request, Consumer<ConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToConfigurationUpdate operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToConfigurationUpdateResponse>,SubscribeToConfigurationUpdateResponseHandler>	subscribeToConfigurationUpdateAsync(SubscribeToConfigurationUpdateRequest request, StreamResponseHandler<ConfigurationUpdateEvents> streamResponseHandler)	Perform the subscribeToConfigurationUpdate operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToIoTCoreResponse,SubscribeToIoTCoreResponseHandler>	subscribeToIoTCore(SubscribeToIoTCoreRequest request, Consumer<IoTCoreMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToIoTCore operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToIoTCoreResponse,SubscribeToIoTCoreResponseHandler>	subscribeToIoTCore(SubscribeToIoTCoreRequest request, StreamResponseHandler<IoTCoreMessage> streamResponseHandler)	Perform the subscribeToIoTCore operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>,SubscribeToIoTCoreResponseHandler>	subscribeToIoTCoreAsync(SubscribeToIoTCoreRequest request, Consumer<IoTCoreMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToIoTCore operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>,SubscribeToIoTCoreResponseHandler>	subscribeToIoTCoreAsync(SubscribeToIoTCoreRequest request, StreamResponseHandler<IoTCoreMessage> streamResponseHandler)	Perform the subscribeToIoTCore operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToTopicResponse,SubscribeToTopicResponseHandler>	subscribeToTopic(SubscribeToTopicRequest request, Consumer<SubscriptionResponseMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToTopic operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToTopicResponse,SubscribeToTopicResponseHandler>	subscribeToTopic(SubscribeToTopicRequest request, StreamResponseHandler<SubscriptionResponseMessage> streamResponseHandler)	Perform the subscribeToTopic operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToTopicResponse>,SubscribeToTopicResponseHandler>	subscribeToTopicAsync(SubscribeToTopicRequest request, Consumer<SubscriptionResponseMessage> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToTopic operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToTopicResponse>,SubscribeToTopicResponseHandler>	subscribeToTopicAsync(SubscribeToTopicRequest request, StreamResponseHandler<SubscriptionResponseMessage> streamResponseHandler)	Perform the subscribeToTopic operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToValidateConfigurationUpdatesResponse,SubscribeToValidateConfigurationUpdatesResponseHandler>	subscribeToValidateConfigurationUpdates(SubscribeToValidateConfigurationUpdatesRequest request, Consumer<ValidateConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToValidateConfigurationUpdates operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToValidateConfigurationUpdatesResponse,SubscribeToValidateConfigurationUpdatesResponseHandler>	subscribeToValidateConfigurationUpdates(SubscribeToValidateConfigurationUpdatesRequest request, StreamResponseHandler<ValidateConfigurationUpdateEvents> streamResponseHandler)	Perform the subscribeToValidateConfigurationUpdates operation synchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToValidateConfigurationUpdatesResponse>,SubscribeToValidateConfigurationUpdatesResponseHandler>	subscribeToValidateConfigurationUpdatesAsync(SubscribeToValidateConfigurationUpdatesRequest request, Consumer<ValidateConfigurationUpdateEvents> onStreamEvent, Optional<Function<Throwable,Boolean>> onStreamError, Optional<Runnable> onStreamClosed)	Perform the subscribeToValidateConfigurationUpdates operation asynchronously.
GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToValidateConfigurationUpdatesResponse>,SubscribeToValidateConfigurationUpdatesResponseHandler>	subscribeToValidateConfigurationUpdatesAsync(SubscribeToValidateConfigurationUpdatesRequest request, StreamResponseHandler<ValidateConfigurationUpdateEvents> streamResponseHandler)	Perform the subscribeToValidateConfigurationUpdates operation asynchronously.
UpdateConfigurationResponse	updateConfiguration(UpdateConfigurationRequest request)	Perform the updateConfiguration operation synchronously.
CompletableFuture<UpdateConfigurationResponse>	updateConfigurationAsync(UpdateConfigurationRequest request)	Perform the updateConfiguration operation asynchronously.
UpdateStateResponse	updateState(UpdateStateRequest request)	Perform the updateState operation synchronously.
CompletableFuture<UpdateStateResponse>	updateStateAsync(UpdateStateRequest request)	Perform the updateState operation asynchronously.
UpdateThingShadowResponse	updateThingShadow(UpdateThingShadowRequest request)	Perform the updateThingShadow operation synchronously.
CompletableFuture<UpdateThingShadowResponse>	updateThingShadowAsync(UpdateThingShadowRequest request)	Perform the updateThingShadow operation asynchronously.
ValidateAuthorizationTokenResponse	validateAuthorizationToken(ValidateAuthorizationTokenRequest request)	Perform the validateAuthorizationToken operation synchronously.
CompletableFuture<ValidateAuthorizationTokenResponse>	validateAuthorizationTokenAsync(ValidateAuthorizationTokenRequest request)	Perform the validateAuthorizationToken operation asynchronously.
VerifyClientDeviceIdentityResponse	verifyClientDeviceIdentity(VerifyClientDeviceIdentityRequest request)	Perform the verifyClientDeviceIdentity operation synchronously.
CompletableFuture<VerifyClientDeviceIdentityResponse>	verifyClientDeviceIdentityAsync(VerifyClientDeviceIdentityRequest request)	Perform the verifyClientDeviceIdentity operation asynchronously.

Methods inherited from class java.lang.Object

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

Method Details

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getClient

public GreengrassCoreIPC getClient()

builder

public static GreengrassCoreIPCClientV2.Builder builder()

authorizeClientDeviceAction

public AuthorizeClientDeviceActionResponse authorizeClientDeviceAction(AuthorizeClientDeviceActionRequest request)
                                                                throws InterruptedException

Perform the authorizeClientDeviceAction operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

authorizeClientDeviceActionAsync

public CompletableFuture<AuthorizeClientDeviceActionResponse> authorizeClientDeviceActionAsync(AuthorizeClientDeviceActionRequest request)

Perform the authorizeClientDeviceAction operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

cancelLocalDeployment

public CancelLocalDeploymentResponse cancelLocalDeployment(CancelLocalDeploymentRequest request)
                                                    throws InterruptedException

Perform the cancelLocalDeployment operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

cancelLocalDeploymentAsync

public CompletableFuture<CancelLocalDeploymentResponse> cancelLocalDeploymentAsync(CancelLocalDeploymentRequest request)

Perform the cancelLocalDeployment operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

createDebugPassword

public CreateDebugPasswordResponse createDebugPassword(CreateDebugPasswordRequest request)
                                                throws InterruptedException

Perform the createDebugPassword operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

createDebugPasswordAsync

public CompletableFuture<CreateDebugPasswordResponse> createDebugPasswordAsync(CreateDebugPasswordRequest request)

Perform the createDebugPassword operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

createLocalDeployment

public CreateLocalDeploymentResponse createLocalDeployment(CreateLocalDeploymentRequest request)
                                                    throws InterruptedException

Perform the createLocalDeployment operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

createLocalDeploymentAsync

public CompletableFuture<CreateLocalDeploymentResponse> createLocalDeploymentAsync(CreateLocalDeploymentRequest request)

Perform the createLocalDeployment operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

deferComponentUpdate

public DeferComponentUpdateResponse deferComponentUpdate(DeferComponentUpdateRequest request)
                                                  throws InterruptedException

Perform the deferComponentUpdate operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

deferComponentUpdateAsync

public CompletableFuture<DeferComponentUpdateResponse> deferComponentUpdateAsync(DeferComponentUpdateRequest request)

Perform the deferComponentUpdate operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

deleteThingShadow

public DeleteThingShadowResponse deleteThingShadow(DeleteThingShadowRequest request)
                                            throws InterruptedException

Perform the deleteThingShadow operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

deleteThingShadowAsync

public CompletableFuture<DeleteThingShadowResponse> deleteThingShadowAsync(DeleteThingShadowRequest request)

Perform the deleteThingShadow operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

getClientDeviceAuthToken

public GetClientDeviceAuthTokenResponse getClientDeviceAuthToken(GetClientDeviceAuthTokenRequest request)
                                                          throws InterruptedException

Perform the getClientDeviceAuthToken operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

getClientDeviceAuthTokenAsync

public CompletableFuture<GetClientDeviceAuthTokenResponse> getClientDeviceAuthTokenAsync(GetClientDeviceAuthTokenRequest request)

Perform the getClientDeviceAuthToken operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

getComponentDetails

public GetComponentDetailsResponse getComponentDetails(GetComponentDetailsRequest request)
                                                throws InterruptedException

Perform the getComponentDetails operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

getComponentDetailsAsync

public CompletableFuture<GetComponentDetailsResponse> getComponentDetailsAsync(GetComponentDetailsRequest request)

Perform the getComponentDetails operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

getConfiguration

public GetConfigurationResponse getConfiguration(GetConfigurationRequest request)
                                          throws InterruptedException

Perform the getConfiguration operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

getConfigurationAsync

public CompletableFuture<GetConfigurationResponse> getConfigurationAsync(GetConfigurationRequest request)

Perform the getConfiguration operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

getLocalDeploymentStatus

public GetLocalDeploymentStatusResponse getLocalDeploymentStatus(GetLocalDeploymentStatusRequest request)
                                                          throws InterruptedException

Perform the getLocalDeploymentStatus operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

getLocalDeploymentStatusAsync

public CompletableFuture<GetLocalDeploymentStatusResponse> getLocalDeploymentStatusAsync(GetLocalDeploymentStatusRequest request)

Perform the getLocalDeploymentStatus operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

getSecretValue

public GetSecretValueResponse getSecretValue(GetSecretValueRequest request)
                                      throws InterruptedException

Perform the getSecretValue operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

getSecretValueAsync

public CompletableFuture<GetSecretValueResponse> getSecretValueAsync(GetSecretValueRequest request)

Perform the getSecretValue operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

getThingShadow

public GetThingShadowResponse getThingShadow(GetThingShadowRequest request)
                                      throws InterruptedException

Perform the getThingShadow operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

getThingShadowAsync

public CompletableFuture<GetThingShadowResponse> getThingShadowAsync(GetThingShadowRequest request)

Perform the getThingShadow operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

listComponents

public ListComponentsResponse listComponents(ListComponentsRequest request)
                                      throws InterruptedException

Perform the listComponents operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

listComponentsAsync

public CompletableFuture<ListComponentsResponse> listComponentsAsync(ListComponentsRequest request)

Perform the listComponents operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

listLocalDeployments

public ListLocalDeploymentsResponse listLocalDeployments(ListLocalDeploymentsRequest request)
                                                  throws InterruptedException

Perform the listLocalDeployments operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

listLocalDeploymentsAsync

public CompletableFuture<ListLocalDeploymentsResponse> listLocalDeploymentsAsync(ListLocalDeploymentsRequest request)

Perform the listLocalDeployments operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

listNamedShadowsForThing

public ListNamedShadowsForThingResponse listNamedShadowsForThing(ListNamedShadowsForThingRequest request)
                                                          throws InterruptedException

Perform the listNamedShadowsForThing operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

listNamedShadowsForThingAsync

public CompletableFuture<ListNamedShadowsForThingResponse> listNamedShadowsForThingAsync(ListNamedShadowsForThingRequest request)

Perform the listNamedShadowsForThing operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

pauseComponent

public PauseComponentResponse pauseComponent(PauseComponentRequest request)
                                      throws InterruptedException

Perform the pauseComponent operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

pauseComponentAsync

public CompletableFuture<PauseComponentResponse> pauseComponentAsync(PauseComponentRequest request)

Perform the pauseComponent operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

publishToIoTCore

public PublishToIoTCoreResponse publishToIoTCore(PublishToIoTCoreRequest request)
                                          throws InterruptedException

Perform the publishToIoTCore operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

publishToIoTCoreAsync

public CompletableFuture<PublishToIoTCoreResponse> publishToIoTCoreAsync(PublishToIoTCoreRequest request)

Perform the publishToIoTCore operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

publishToTopic

public PublishToTopicResponse publishToTopic(PublishToTopicRequest request)
                                      throws InterruptedException

Perform the publishToTopic operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

publishToTopicAsync

public CompletableFuture<PublishToTopicResponse> publishToTopicAsync(PublishToTopicRequest request)

Perform the publishToTopic operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

putComponentMetric

public PutComponentMetricResponse putComponentMetric(PutComponentMetricRequest request)
                                              throws InterruptedException

Perform the putComponentMetric operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

putComponentMetricAsync

public CompletableFuture<PutComponentMetricResponse> putComponentMetricAsync(PutComponentMetricRequest request)

Perform the putComponentMetric operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

restartComponent

public RestartComponentResponse restartComponent(RestartComponentRequest request)
                                          throws InterruptedException

Perform the restartComponent operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

restartComponentAsync

public CompletableFuture<RestartComponentResponse> restartComponentAsync(RestartComponentRequest request)

Perform the restartComponent operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

resumeComponent

public ResumeComponentResponse resumeComponent(ResumeComponentRequest request)
                                        throws InterruptedException

Perform the resumeComponent operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

resumeComponentAsync

public CompletableFuture<ResumeComponentResponse> resumeComponentAsync(ResumeComponentRequest request)

Perform the resumeComponent operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

sendConfigurationValidityReport

public SendConfigurationValidityReportResponse sendConfigurationValidityReport(SendConfigurationValidityReportRequest request)
                                                                        throws InterruptedException

Perform the sendConfigurationValidityReport operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

sendConfigurationValidityReportAsync

public CompletableFuture<SendConfigurationValidityReportResponse> sendConfigurationValidityReportAsync(SendConfigurationValidityReportRequest request)

Perform the sendConfigurationValidityReport operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

stopComponent

public StopComponentResponse stopComponent(StopComponentRequest request)
                                    throws InterruptedException

Perform the stopComponent operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

stopComponentAsync

public CompletableFuture<StopComponentResponse> stopComponentAsync(StopComponentRequest request)

Perform the stopComponent operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

subscribeToCertificateUpdatesAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToCertificateUpdatesResponse>,SubscribeToCertificateUpdatesResponseHandler> subscribeToCertificateUpdatesAsync(SubscribeToCertificateUpdatesRequest request,
 Consumer<CertificateUpdateEvent> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)

Perform the subscribeToCertificateUpdates operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

a future which resolves to the response

subscribeToCertificateUpdates

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToCertificateUpdatesResponse,SubscribeToCertificateUpdatesResponseHandler> subscribeToCertificateUpdates(SubscribeToCertificateUpdatesRequest request,
 Consumer<CertificateUpdateEvent> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)
                                                                                                                                                              throws InterruptedException

Perform the subscribeToCertificateUpdates operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToCertificateUpdates

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToCertificateUpdatesResponse,SubscribeToCertificateUpdatesResponseHandler> subscribeToCertificateUpdates(SubscribeToCertificateUpdatesRequest request,
 StreamResponseHandler<CertificateUpdateEvent> streamResponseHandler)
                                                                                                                                                              throws InterruptedException

Perform the subscribeToCertificateUpdates operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToCertificateUpdatesAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToCertificateUpdatesResponse>,SubscribeToCertificateUpdatesResponseHandler> subscribeToCertificateUpdatesAsync(SubscribeToCertificateUpdatesRequest request,
 StreamResponseHandler<CertificateUpdateEvent> streamResponseHandler)

Perform the subscribeToCertificateUpdates operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

a future which resolves to the response

subscribeToComponentUpdatesAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToComponentUpdatesResponse>,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdatesAsync(SubscribeToComponentUpdatesRequest request,
 Consumer<ComponentUpdatePolicyEvents> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)

Perform the subscribeToComponentUpdates operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

a future which resolves to the response

subscribeToComponentUpdates

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToComponentUpdatesResponse,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdates(SubscribeToComponentUpdatesRequest request,
 Consumer<ComponentUpdatePolicyEvents> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)
                                                                                                                                                        throws InterruptedException

Perform the subscribeToComponentUpdates operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToComponentUpdates

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToComponentUpdatesResponse,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdates(SubscribeToComponentUpdatesRequest request,
 StreamResponseHandler<ComponentUpdatePolicyEvents> streamResponseHandler)
                                                                                                                                                        throws InterruptedException

Perform the subscribeToComponentUpdates operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToComponentUpdatesAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToComponentUpdatesResponse>,SubscribeToComponentUpdatesResponseHandler> subscribeToComponentUpdatesAsync(SubscribeToComponentUpdatesRequest request,
 StreamResponseHandler<ComponentUpdatePolicyEvents> streamResponseHandler)

Perform the subscribeToComponentUpdates operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

a future which resolves to the response

subscribeToConfigurationUpdateAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToConfigurationUpdateResponse>,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdateAsync(SubscribeToConfigurationUpdateRequest request,
 Consumer<ConfigurationUpdateEvents> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)

Perform the subscribeToConfigurationUpdate operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

a future which resolves to the response

subscribeToConfigurationUpdate

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToConfigurationUpdateResponse,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdate(SubscribeToConfigurationUpdateRequest request,
 Consumer<ConfigurationUpdateEvents> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)
                                                                                                                                                                 throws InterruptedException

Perform the subscribeToConfigurationUpdate operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToConfigurationUpdate

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToConfigurationUpdateResponse,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdate(SubscribeToConfigurationUpdateRequest request,
 StreamResponseHandler<ConfigurationUpdateEvents> streamResponseHandler)
                                                                                                                                                                 throws InterruptedException

Perform the subscribeToConfigurationUpdate operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToConfigurationUpdateAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToConfigurationUpdateResponse>,SubscribeToConfigurationUpdateResponseHandler> subscribeToConfigurationUpdateAsync(SubscribeToConfigurationUpdateRequest request,
 StreamResponseHandler<ConfigurationUpdateEvents> streamResponseHandler)

Perform the subscribeToConfigurationUpdate operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

a future which resolves to the response

subscribeToIoTCoreAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>,SubscribeToIoTCoreResponseHandler> subscribeToIoTCoreAsync(SubscribeToIoTCoreRequest request,
 Consumer<IoTCoreMessage> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)

Perform the subscribeToIoTCore operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

a future which resolves to the response

subscribeToIoTCore

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToIoTCoreResponse,SubscribeToIoTCoreResponseHandler> subscribeToIoTCore(SubscribeToIoTCoreRequest request,
 Consumer<IoTCoreMessage> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)
                                                                                                                             throws InterruptedException

Perform the subscribeToIoTCore operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToIoTCore

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToIoTCoreResponse,SubscribeToIoTCoreResponseHandler> subscribeToIoTCore(SubscribeToIoTCoreRequest request,
 StreamResponseHandler<IoTCoreMessage> streamResponseHandler)
                                                                                                                             throws InterruptedException

Perform the subscribeToIoTCore operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToIoTCoreAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>,SubscribeToIoTCoreResponseHandler> subscribeToIoTCoreAsync(SubscribeToIoTCoreRequest request,
 StreamResponseHandler<IoTCoreMessage> streamResponseHandler)

Perform the subscribeToIoTCore operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

a future which resolves to the response

subscribeToTopicAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToTopicResponse>,SubscribeToTopicResponseHandler> subscribeToTopicAsync(SubscribeToTopicRequest request,
 Consumer<SubscriptionResponseMessage> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)

Perform the subscribeToTopic operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

a future which resolves to the response

subscribeToTopic

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToTopicResponse,SubscribeToTopicResponseHandler> subscribeToTopic(SubscribeToTopicRequest request,
 Consumer<SubscriptionResponseMessage> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)
                                                                                                                       throws InterruptedException

Perform the subscribeToTopic operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToTopic

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToTopicResponse,SubscribeToTopicResponseHandler> subscribeToTopic(SubscribeToTopicRequest request,
 StreamResponseHandler<SubscriptionResponseMessage> streamResponseHandler)
                                                                                                                       throws InterruptedException

Perform the subscribeToTopic operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToTopicAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToTopicResponse>,SubscribeToTopicResponseHandler> subscribeToTopicAsync(SubscribeToTopicRequest request,
 StreamResponseHandler<SubscriptionResponseMessage> streamResponseHandler)

Perform the subscribeToTopic operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

a future which resolves to the response

subscribeToValidateConfigurationUpdatesAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToValidateConfigurationUpdatesResponse>,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdatesAsync(SubscribeToValidateConfigurationUpdatesRequest request,
 Consumer<ValidateConfigurationUpdateEvents> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)

Perform the subscribeToValidateConfigurationUpdates operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

a future which resolves to the response

subscribeToValidateConfigurationUpdates

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToValidateConfigurationUpdatesResponse,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdates(SubscribeToValidateConfigurationUpdatesRequest request,
 Consumer<ValidateConfigurationUpdateEvents> onStreamEvent,
 Optional<Function<Throwable,Boolean>> onStreamError,
 Optional<Runnable> onStreamClosed)
                                                                                                                                                                                            throws InterruptedException

Perform the subscribeToValidateConfigurationUpdates operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

onStreamEvent - Callback for stream events. If an executor is provided, this method will run in the executor.

onStreamError - Callback for stream errors. Return true to close the stream, return false to keep the stream open. Even if an executor is provided, this method will not run in the executor.

onStreamClosed - Callback for when the stream closes. If an executor is provided, this method will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToValidateConfigurationUpdates

public GreengrassCoreIPCClientV2.StreamingResponse<SubscribeToValidateConfigurationUpdatesResponse,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdates(SubscribeToValidateConfigurationUpdatesRequest request,
 StreamResponseHandler<ValidateConfigurationUpdateEvents> streamResponseHandler)
                                                                                                                                                                                            throws InterruptedException

Perform the subscribeToValidateConfigurationUpdates operation synchronously. The initial response or error will be returned synchronously, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

subscribeToValidateConfigurationUpdatesAsync

public GreengrassCoreIPCClientV2.StreamingResponse<CompletableFuture<SubscribeToValidateConfigurationUpdatesResponse>,SubscribeToValidateConfigurationUpdatesResponseHandler> subscribeToValidateConfigurationUpdatesAsync(SubscribeToValidateConfigurationUpdatesRequest request,
 StreamResponseHandler<ValidateConfigurationUpdateEvents> streamResponseHandler)

Perform the subscribeToValidateConfigurationUpdates operation asynchronously. The initial response or error will be returned as the result of the asynchronous future, further events will arrive via the streaming callbacks.

Parameters:

request - request object

streamResponseHandler - Methods on this object will be called as stream events happen on this operation. If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.

Returns:

a future which resolves to the response

updateConfiguration

public UpdateConfigurationResponse updateConfiguration(UpdateConfigurationRequest request)
                                                throws InterruptedException

Perform the updateConfiguration operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

updateConfigurationAsync

public CompletableFuture<UpdateConfigurationResponse> updateConfigurationAsync(UpdateConfigurationRequest request)

Perform the updateConfiguration operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

updateState

public UpdateStateResponse updateState(UpdateStateRequest request)
                                throws InterruptedException

Perform the updateState operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

updateStateAsync

public CompletableFuture<UpdateStateResponse> updateStateAsync(UpdateStateRequest request)

Perform the updateState operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

updateThingShadow

public UpdateThingShadowResponse updateThingShadow(UpdateThingShadowRequest request)
                                            throws InterruptedException

Perform the updateThingShadow operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

updateThingShadowAsync

public CompletableFuture<UpdateThingShadowResponse> updateThingShadowAsync(UpdateThingShadowRequest request)

Perform the updateThingShadow operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

validateAuthorizationToken

public ValidateAuthorizationTokenResponse validateAuthorizationToken(ValidateAuthorizationTokenRequest request)
                                                              throws InterruptedException

Perform the validateAuthorizationToken operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

validateAuthorizationTokenAsync

public CompletableFuture<ValidateAuthorizationTokenResponse> validateAuthorizationTokenAsync(ValidateAuthorizationTokenRequest request)

Perform the validateAuthorizationToken operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response

verifyClientDeviceIdentity

public VerifyClientDeviceIdentityResponse verifyClientDeviceIdentity(VerifyClientDeviceIdentityRequest request)
                                                              throws InterruptedException

Perform the verifyClientDeviceIdentity operation synchronously.

Parameters:

request - request object

Returns:

the response

Throws:

InterruptedException - if thread is interrupted while waiting for the response

verifyClientDeviceIdentityAsync

public CompletableFuture<VerifyClientDeviceIdentityResponse> verifyClientDeviceIdentityAsync(VerifyClientDeviceIdentityRequest request)

Perform the verifyClientDeviceIdentity operation asynchronously.

Parameters:

request - request object

Returns:

a future which resolves to the response