Skip to content

Commit 4183a48

Browse files
author
Bret Ambrose
committed
New operation and modeled types
1 parent 67ddca3 commit 4183a48

11 files changed

Lines changed: 640 additions & 0 deletions

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPC.java‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
2424
import software.amazon.awssdk.aws.greengrass.model.GetSecretValueRequest;
2525
import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest;
26+
import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
2627
import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
2728
import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest;
2829
import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsRequest;
@@ -38,6 +39,7 @@
3839
import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
3940
import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
4041
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
42+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
4143
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
4244
import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
4345
import software.amazon.awssdk.aws.greengrass.model.SubscribeToValidateConfigurationUpdatesRequest;
@@ -145,6 +147,10 @@ SubscribeToConfigurationUpdateResponseHandler subscribeToConfigurationUpdate(
145147
SubscribeToIoTCoreResponseHandler subscribeToIoTCore(final SubscribeToIoTCoreRequest request,
146148
final Optional<StreamResponseHandler<IoTCoreMessage>> streamResponseHandler);
147149

150+
SubscribeToIoTCoreConnectionStatusResponseHandler subscribeToIoTCoreConnectionStatus(
151+
final SubscribeToIoTCoreConnectionStatusRequest request,
152+
final Optional<StreamResponseHandler<IoTCoreConnectionStatusEvent>> streamResponseHandler);
153+
148154
SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request,
149155
final Optional<StreamResponseHandler<SubscriptionResponseMessage>> streamResponseHandler);
150156

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClient.java‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
2525
import software.amazon.awssdk.aws.greengrass.model.GetSecretValueRequest;
2626
import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest;
27+
import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
2728
import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
2829
import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest;
2930
import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsRequest;
@@ -39,6 +40,7 @@
3940
import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
4041
import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
4142
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
43+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
4244
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
4345
import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
4446
import software.amazon.awssdk.aws.greengrass.model.SubscribeToValidateConfigurationUpdatesRequest;
@@ -264,6 +266,14 @@ public SubscribeToIoTCoreResponseHandler subscribeToIoTCore(
264266
return new SubscribeToIoTCoreResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
265267
}
266268

269+
@Override
270+
public SubscribeToIoTCoreConnectionStatusResponseHandler subscribeToIoTCoreConnectionStatus(
271+
final SubscribeToIoTCoreConnectionStatusRequest request,
272+
final Optional<StreamResponseHandler<IoTCoreConnectionStatusEvent>> streamResponseHandler) {
273+
final SubscribeToIoTCoreConnectionStatusOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToIoTCoreConnectionStatusModelContext();
274+
return new SubscribeToIoTCoreConnectionStatusResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
275+
}
276+
267277
@Override
268278
public SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request,
269279
final Optional<StreamResponseHandler<SubscriptionResponseMessage>> streamResponseHandler) {

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClientV2.java‎

Lines changed: 86 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@
5353
import software.amazon.awssdk.aws.greengrass.model.GetSecretValueResponse;
5454
import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest;
5555
import software.amazon.awssdk.aws.greengrass.model.GetThingShadowResponse;
56+
import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
5657
import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
5758
import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest;
5859
import software.amazon.awssdk.aws.greengrass.model.ListComponentsResponse;
@@ -82,6 +83,8 @@
8283
import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesResponse;
8384
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
8485
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateResponse;
86+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
87+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusResponse;
8588
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
8689
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreResponse;
8790
import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
@@ -1049,6 +1052,89 @@ public StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>, Subscrib
10491052
return new StreamingResponse<>(r.getResponse(), r);
10501053
}
10511054

1055+
/**
1056+
* Perform the subscribeToIoTCoreConnectionStatus operation asynchronously.
1057+
* The initial response or error will be returned as the result of the asynchronous future, further events will
1058+
* arrive via the streaming callbacks.
1059+
*
1060+
* @return a future which resolves to the response
1061+
*
1062+
* @param request request object
1063+
* @param onStreamEvent Callback for stream events. If an executor is provided, this method will run in the executor.
1064+
* @param onStreamError Callback for stream errors. Return true to close the stream,
1065+
* return false to keep the stream open. Even if an executor is provided,
1066+
* this method will not run in the executor.
1067+
* @param onStreamClosed Callback for when the stream closes. If an executor is provided, this method will run in the executor.
1068+
*/
1069+
public StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatusAsync(
1070+
final SubscribeToIoTCoreConnectionStatusRequest request,
1071+
Consumer<IoTCoreConnectionStatusEvent> onStreamEvent,
1072+
Optional<Function<Throwable, Boolean>> onStreamError, Optional<Runnable> onStreamClosed) {
1073+
return this.subscribeToIoTCoreConnectionStatusAsync(request, getStreamingResponseHandler(onStreamEvent, onStreamError, onStreamClosed));
1074+
}
1075+
1076+
/**
1077+
* Perform the subscribeToIoTCoreConnectionStatus operation synchronously.
1078+
* The initial response or error will be returned synchronously,
1079+
* further events will arrive via the streaming callbacks.
1080+
*
1081+
* @throws InterruptedException if thread is interrupted while waiting for the response
1082+
* @return the response
1083+
*
1084+
* @param request request object
1085+
* @param onStreamEvent Callback for stream events. If an executor is provided, this method will run in the executor.
1086+
* @param onStreamError Callback for stream errors. Return true to close the stream,
1087+
* return false to keep the stream open. Even if an executor is provided,
1088+
* this method will not run in the executor.
1089+
* @param onStreamClosed Callback for when the stream closes. If an executor is provided, this method will run in the executor.
1090+
*/
1091+
public StreamingResponse<SubscribeToIoTCoreConnectionStatusResponse, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatus(
1092+
final SubscribeToIoTCoreConnectionStatusRequest request,
1093+
Consumer<IoTCoreConnectionStatusEvent> onStreamEvent,
1094+
Optional<Function<Throwable, Boolean>> onStreamError, Optional<Runnable> onStreamClosed)
1095+
throws InterruptedException {
1096+
StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> r = this.subscribeToIoTCoreConnectionStatusAsync(request, onStreamEvent, onStreamError, onStreamClosed);
1097+
return new StreamingResponse<>(getResponse(r.getResponse()), r.getHandler());
1098+
}
1099+
1100+
/**
1101+
* Perform the subscribeToIoTCoreConnectionStatus operation synchronously.
1102+
* The initial response or error will be returned synchronously, further events will
1103+
* arrive via the streaming callbacks.
1104+
*
1105+
* @throws InterruptedException if thread is interrupted while waiting for the response
1106+
* @return the response
1107+
*
1108+
* @param request request object
1109+
* @param streamResponseHandler Methods on this object will be called as stream events happen on this operation.
1110+
* If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.
1111+
*/
1112+
public StreamingResponse<SubscribeToIoTCoreConnectionStatusResponse, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatus(
1113+
final SubscribeToIoTCoreConnectionStatusRequest request,
1114+
final StreamResponseHandler<IoTCoreConnectionStatusEvent> streamResponseHandler) throws
1115+
InterruptedException {
1116+
StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> r = this.subscribeToIoTCoreConnectionStatusAsync(request, streamResponseHandler);
1117+
return new StreamingResponse<>(getResponse(r.getResponse()), r.getHandler());
1118+
}
1119+
1120+
/**
1121+
* Perform the subscribeToIoTCoreConnectionStatus operation asynchronously.
1122+
* The initial response or error will be returned as the result of the asynchronous future, further events will
1123+
* arrive via the streaming callbacks.
1124+
*
1125+
* @return a future which resolves to the response
1126+
*
1127+
* @param request request object
1128+
* @param streamResponseHandler Methods on this object will be called as stream events happen on this operation.
1129+
* If an executor is provided, the onStreamEvent and onStreamClosed methods will run in the executor.
1130+
*/
1131+
public StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatusAsync(
1132+
final SubscribeToIoTCoreConnectionStatusRequest request,
1133+
final StreamResponseHandler<IoTCoreConnectionStatusEvent> streamResponseHandler) {
1134+
SubscribeToIoTCoreConnectionStatusResponseHandler r = client.subscribeToIoTCoreConnectionStatus(request, Optional.ofNullable(getStreamingResponseHandler(streamResponseHandler)));
1135+
return new StreamingResponse<>(r.getResponse(), r);
1136+
}
1137+
10521138
/**
10531139
* Perform the subscribeToTopic operation asynchronously.
10541140
* The initial response or error will be returned as the result of the asynchronous future, further events will

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/SubscribeToIoTCoreConnectionStatusResponseHandler.java‎

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,50 @@
1+
/**
2+
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
* SPDX-License-Identifier: Apache-2.0.
4+
*
5+
* This file is generated.
6+
*/
7+
8+
package software.amazon.awssdk.aws.greengrass;
9+
10+
import java.lang.Override;
11+
import java.lang.Void;
12+
import java.util.concurrent.CompletableFuture;
13+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusResponse;
14+
import software.amazon.awssdk.eventstreamrpc.OperationResponse;
15+
import software.amazon.awssdk.eventstreamrpc.StreamResponse;
16+
import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
17+
18+
public final class SubscribeToIoTCoreConnectionStatusResponseHandler implements StreamResponse<SubscribeToIoTCoreConnectionStatusResponse, EventStreamJsonMessage> {
19+
private final OperationResponse<SubscribeToIoTCoreConnectionStatusResponse, EventStreamJsonMessage> operationResponse;
20+
21+
public SubscribeToIoTCoreConnectionStatusResponseHandler(
22+
final OperationResponse<SubscribeToIoTCoreConnectionStatusResponse, EventStreamJsonMessage> operationResponse) {
23+
this.operationResponse = operationResponse;
24+
}
25+
26+
@Override
27+
public CompletableFuture<Void> getRequestFlushFuture() {
28+
return operationResponse.getRequestFlushFuture();
29+
}
30+
31+
@Override
32+
public CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse> getResponse() {
33+
return operationResponse.getResponse();
34+
}
35+
36+
@Override
37+
public CompletableFuture<Void> sendStreamEvent(final EventStreamJsonMessage event) {
38+
return operationResponse.sendStreamEvent(event);
39+
}
40+
41+
@Override
42+
public CompletableFuture<Void> closeStream() {
43+
return operationResponse.closeStream();
44+
}
45+
46+
@Override
47+
public boolean isClosed() {
48+
return operationResponse.isClosed();
49+
}
50+
}

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/model/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCServiceModel.java‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,8 @@
3434
import software.amazon.awssdk.aws.greengrass.model.ConfigurationValidityReport;
3535
import software.amazon.awssdk.aws.greengrass.model.ConfigurationValidityStatus;
3636
import software.amazon.awssdk.aws.greengrass.model.ConflictError;
37+
import software.amazon.awssdk.aws.greengrass.model.ConnectionStatus;
38+
import software.amazon.awssdk.aws.greengrass.model.ConnectionStatusEvent;
3739
import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordRequest;
3840
import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordResponse;
3941
import software.amazon.awssdk.aws.greengrass.model.CreateLocalDeploymentRequest;
@@ -66,6 +68,7 @@
6668
import software.amazon.awssdk.aws.greengrass.model.InvalidCredentialError;
6769
import software.amazon.awssdk.aws.greengrass.model.InvalidRecipeDirectoryPathError;
6870
import software.amazon.awssdk.aws.greengrass.model.InvalidTokenError;
71+
import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
6972
import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
7073
import software.amazon.awssdk.aws.greengrass.model.JsonMessage;
7174
import software.amazon.awssdk.aws.greengrass.model.LifecycleState;
@@ -115,6 +118,8 @@
115118
import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesResponse;
116119
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
117120
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateResponse;
121+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
122+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusResponse;
118123
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
119124
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreResponse;
120125
import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
@@ -262,6 +267,10 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
262267

263268
private static final SubscribeToIoTCoreOperationContext _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT = new SubscribeToIoTCoreOperationContext();
264269

270+
public static final String SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS = SERVICE_NAMESPACE + "#" + "SubscribeToIoTCoreConnectionStatus";
271+
272+
private static final SubscribeToIoTCoreConnectionStatusOperationContext _SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS_OPERATION_CONTEXT = new SubscribeToIoTCoreConnectionStatusOperationContext();
273+
265274
public static final String SUBSCRIBE_TO_TOPIC = SERVICE_NAMESPACE + "#" + "SubscribeToTopic";
266275

267276
private static final SubscribeToTopicOperationContext _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT = new SubscribeToTopicOperationContext();
@@ -345,6 +354,8 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
345354
SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_CONFIGURATION_UPDATE);
346355
SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_IOT_CORE, _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT);
347356
SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_IOT_CORE);
357+
SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS, _SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS_OPERATION_CONTEXT);
358+
SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS);
348359
SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_TOPIC, _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT);
349360
SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_TOPIC);
350361
SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES, _SUBSCRIBE_TO_VALIDATE_CONFIGURATION_UPDATES_OPERATION_CONTEXT);
@@ -377,6 +388,8 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
377388
SERVICE_OBJECT_MODEL_MAP.put(ConfigurationValidityReport.APPLICATION_MODEL_TYPE, ConfigurationValidityReport.class);
378389
SERVICE_OBJECT_MODEL_MAP.put(ConfigurationValidityStatus.APPLICATION_MODEL_TYPE, ConfigurationValidityStatus.class);
379390
SERVICE_OBJECT_MODEL_MAP.put(ConflictError.APPLICATION_MODEL_TYPE, ConflictError.class);
391+
SERVICE_OBJECT_MODEL_MAP.put(ConnectionStatus.APPLICATION_MODEL_TYPE, ConnectionStatus.class);
392+
SERVICE_OBJECT_MODEL_MAP.put(ConnectionStatusEvent.APPLICATION_MODEL_TYPE, ConnectionStatusEvent.class);
380393
SERVICE_OBJECT_MODEL_MAP.put(CreateDebugPasswordRequest.APPLICATION_MODEL_TYPE, CreateDebugPasswordRequest.class);
381394
SERVICE_OBJECT_MODEL_MAP.put(CreateDebugPasswordResponse.APPLICATION_MODEL_TYPE, CreateDebugPasswordResponse.class);
382395
SERVICE_OBJECT_MODEL_MAP.put(CreateLocalDeploymentRequest.APPLICATION_MODEL_TYPE, CreateLocalDeploymentRequest.class);
@@ -409,6 +422,7 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
409422
SERVICE_OBJECT_MODEL_MAP.put(InvalidCredentialError.APPLICATION_MODEL_TYPE, InvalidCredentialError.class);
410423
SERVICE_OBJECT_MODEL_MAP.put(InvalidRecipeDirectoryPathError.APPLICATION_MODEL_TYPE, InvalidRecipeDirectoryPathError.class);
411424
SERVICE_OBJECT_MODEL_MAP.put(InvalidTokenError.APPLICATION_MODEL_TYPE, InvalidTokenError.class);
425+
SERVICE_OBJECT_MODEL_MAP.put(IoTCoreConnectionStatusEvent.APPLICATION_MODEL_TYPE, IoTCoreConnectionStatusEvent.class);
412426
SERVICE_OBJECT_MODEL_MAP.put(IoTCoreMessage.APPLICATION_MODEL_TYPE, IoTCoreMessage.class);
413427
SERVICE_OBJECT_MODEL_MAP.put(JsonMessage.APPLICATION_MODEL_TYPE, JsonMessage.class);
414428
SERVICE_OBJECT_MODEL_MAP.put(LifecycleState.APPLICATION_MODEL_TYPE, LifecycleState.class);
@@ -458,6 +472,8 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
458472
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToComponentUpdatesResponse.APPLICATION_MODEL_TYPE, SubscribeToComponentUpdatesResponse.class);
459473
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToConfigurationUpdateRequest.APPLICATION_MODEL_TYPE, SubscribeToConfigurationUpdateRequest.class);
460474
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToConfigurationUpdateResponse.APPLICATION_MODEL_TYPE, SubscribeToConfigurationUpdateResponse.class);
475+
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreConnectionStatusRequest.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreConnectionStatusRequest.class);
476+
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreConnectionStatusResponse.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreConnectionStatusResponse.class);
461477
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreRequest.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreRequest.class);
462478
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreResponse.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreResponse.class);
463479
SERVICE_OBJECT_MODEL_MAP.put(SubscribeToTopicRequest.APPLICATION_MODEL_TYPE, SubscribeToTopicRequest.class);
@@ -607,6 +623,11 @@ public static SubscribeToIoTCoreOperationContext getSubscribeToIoTCoreModelConte
607623
return _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT;
608624
}
609625

626+
public static SubscribeToIoTCoreConnectionStatusOperationContext getSubscribeToIoTCoreConnectionStatusModelContext(
627+
) {
628+
return _SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS_OPERATION_CONTEXT;
629+
}
630+
610631
public static SubscribeToTopicOperationContext getSubscribeToTopicModelContext() {
611632
return _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT;
612633
}

0 commit comments

Comments
 (0)