Greengrass update

.github/workflows/ci.yml

@@ -7,7 +7,7 @@ on:
       - 'docs'
 
 env:
-  BUILDER_VERSION: v0.9.84
+  BUILDER_VERSION: v0.9.94
   BUILDER_SOURCE: releases
   BUILDER_HOST: https://d19elf31gohf1l.cloudfront.net
   PACKAGE_NAME: aws-iot-device-sdk-java-v2

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

@@ -23,6 +23,7 @@
 import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetSecretValueRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest;
+import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
 import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
 import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest;
 import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsRequest;
@@ -38,6 +39,7 @@
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToValidateConfigurationUpdatesRequest;
@@ -145,6 +147,10 @@ SubscribeToConfigurationUpdateResponseHandler subscribeToConfigurationUpdate(
   SubscribeToIoTCoreResponseHandler subscribeToIoTCore(final SubscribeToIoTCoreRequest request,
       final Optional<StreamResponseHandler<IoTCoreMessage>> streamResponseHandler);
 
+  SubscribeToIoTCoreConnectionStatusResponseHandler subscribeToIoTCoreConnectionStatus(
+      final SubscribeToIoTCoreConnectionStatusRequest request,
+      final Optional<StreamResponseHandler<IoTCoreConnectionStatusEvent>> streamResponseHandler);
+
   SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request,
       final Optional<StreamResponseHandler<SubscriptionResponseMessage>> streamResponseHandler);
 

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

@@ -24,6 +24,7 @@
 import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetSecretValueRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest;
+import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
 import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
 import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest;
 import software.amazon.awssdk.aws.greengrass.model.ListLocalDeploymentsRequest;
@@ -39,6 +40,7 @@
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToValidateConfigurationUpdatesRequest;
@@ -264,6 +266,14 @@ public SubscribeToIoTCoreResponseHandler subscribeToIoTCore(
     return new SubscribeToIoTCoreResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
   }
 
+  @Override
+  public SubscribeToIoTCoreConnectionStatusResponseHandler subscribeToIoTCoreConnectionStatus(
+      final SubscribeToIoTCoreConnectionStatusRequest request,
+      final Optional<StreamResponseHandler<IoTCoreConnectionStatusEvent>> streamResponseHandler) {
+    final SubscribeToIoTCoreConnectionStatusOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToIoTCoreConnectionStatusModelContext();
+    return new SubscribeToIoTCoreConnectionStatusResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
+  }
+
   @Override
   public SubscribeToTopicResponseHandler subscribeToTopic(final SubscribeToTopicRequest request,
       final Optional<StreamResponseHandler<SubscriptionResponseMessage>> streamResponseHandler) {

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

@@ -53,6 +53,7 @@
 import software.amazon.awssdk.aws.greengrass.model.GetSecretValueResponse;
 import software.amazon.awssdk.aws.greengrass.model.GetThingShadowRequest;
 import software.amazon.awssdk.aws.greengrass.model.GetThingShadowResponse;
+import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
 import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
 import software.amazon.awssdk.aws.greengrass.model.ListComponentsRequest;
 import software.amazon.awssdk.aws.greengrass.model.ListComponentsResponse;
@@ -82,6 +83,8 @@
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesResponse;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateResponse;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusResponse;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreResponse;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
@@ -1049,6 +1052,89 @@ public StreamingResponse<CompletableFuture<SubscribeToIoTCoreResponse>, Subscrib
     return new StreamingResponse<>(r.getResponse(), r);
   }
 
+  /**
+   * Perform the subscribeToIoTCoreConnectionStatus 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.
+   *
+   * @return a future which resolves to the response
+   *
+   * @param request request object
+   * @param onStreamEvent Callback for stream events. If an executor is provided, this method will run in the executor.
+   * @param 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.
+   * @param onStreamClosed Callback for when the stream closes. If an executor is provided, this method will run in the executor.
+   */
+  public StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatusAsync(
+      final SubscribeToIoTCoreConnectionStatusRequest request,
+      Consumer<IoTCoreConnectionStatusEvent> onStreamEvent,
+      Optional<Function<Throwable, Boolean>> onStreamError, Optional<Runnable> onStreamClosed) {
+    return this.subscribeToIoTCoreConnectionStatusAsync(request, getStreamingResponseHandler(onStreamEvent, onStreamError, onStreamClosed));
+  }
+
+  /**
+   * Perform the subscribeToIoTCoreConnectionStatus operation synchronously.
+   * The initial response or error will be returned synchronously,
+   * further events will arrive via the streaming callbacks.
+   *
+   * @throws InterruptedException if thread is interrupted while waiting for the response
+   * @return the response
+   *
+   * @param request request object
+   * @param onStreamEvent Callback for stream events. If an executor is provided, this method will run in the executor.
+   * @param 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.
+   * @param onStreamClosed Callback for when the stream closes. If an executor is provided, this method will run in the executor.
+   */
+  public StreamingResponse<SubscribeToIoTCoreConnectionStatusResponse, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatus(
+      final SubscribeToIoTCoreConnectionStatusRequest request,
+      Consumer<IoTCoreConnectionStatusEvent> onStreamEvent,
+      Optional<Function<Throwable, Boolean>> onStreamError, Optional<Runnable> onStreamClosed)
+      throws InterruptedException {
+    StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> r = this.subscribeToIoTCoreConnectionStatusAsync(request, onStreamEvent, onStreamError, onStreamClosed);
+    return new StreamingResponse<>(getResponse(r.getResponse()), r.getHandler());
+  }
+
+  /**
+   * Perform the subscribeToIoTCoreConnectionStatus operation synchronously.
+   * The initial response or error will be returned synchronously, further events will
+   * arrive via the streaming callbacks.
+   *
+   * @throws InterruptedException if thread is interrupted while waiting for the response
+   * @return the response
+   *
+   * @param request request object
+   * @param 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.
+   */
+  public StreamingResponse<SubscribeToIoTCoreConnectionStatusResponse, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatus(
+      final SubscribeToIoTCoreConnectionStatusRequest request,
+      final StreamResponseHandler<IoTCoreConnectionStatusEvent> streamResponseHandler) throws
+      InterruptedException {
+    StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> r = this.subscribeToIoTCoreConnectionStatusAsync(request, streamResponseHandler);
+    return new StreamingResponse<>(getResponse(r.getResponse()), r.getHandler());
+  }
+
+  /**
+   * Perform the subscribeToIoTCoreConnectionStatus 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.
+   *
+   * @return a future which resolves to the response
+   *
+   * @param request request object
+   * @param 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.
+   */
+  public StreamingResponse<CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse>, SubscribeToIoTCoreConnectionStatusResponseHandler> subscribeToIoTCoreConnectionStatusAsync(
+      final SubscribeToIoTCoreConnectionStatusRequest request,
+      final StreamResponseHandler<IoTCoreConnectionStatusEvent> streamResponseHandler) {
+    SubscribeToIoTCoreConnectionStatusResponseHandler r = client.subscribeToIoTCoreConnectionStatus(request, Optional.ofNullable(getStreamingResponseHandler(streamResponseHandler)));
+    return new StreamingResponse<>(r.getResponse(), r);
+  }
+
   /**
    * Perform the subscribeToTopic operation asynchronously.
    * 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

@@ -0,0 +1,50 @@
+/**
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ *
+ * This file is generated.
+ */
+
+package software.amazon.awssdk.aws.greengrass;
+
+import java.lang.Override;
+import java.lang.Void;
+import java.util.concurrent.CompletableFuture;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusResponse;
+import software.amazon.awssdk.eventstreamrpc.OperationResponse;
+import software.amazon.awssdk.eventstreamrpc.StreamResponse;
+import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
+
+public final class SubscribeToIoTCoreConnectionStatusResponseHandler implements StreamResponse<SubscribeToIoTCoreConnectionStatusResponse, EventStreamJsonMessage> {
+  private final OperationResponse<SubscribeToIoTCoreConnectionStatusResponse, EventStreamJsonMessage> operationResponse;
+
+  public SubscribeToIoTCoreConnectionStatusResponseHandler(
+      final OperationResponse<SubscribeToIoTCoreConnectionStatusResponse, EventStreamJsonMessage> operationResponse) {
+    this.operationResponse = operationResponse;
+  }
+
+  @Override
+  public CompletableFuture<Void> getRequestFlushFuture() {
+    return operationResponse.getRequestFlushFuture();
+  }
+
+  @Override
+  public CompletableFuture<SubscribeToIoTCoreConnectionStatusResponse> getResponse() {
+    return operationResponse.getResponse();
+  }
+
+  @Override
+  public CompletableFuture<Void> sendStreamEvent(final EventStreamJsonMessage event) {
+    return operationResponse.sendStreamEvent(event);
+  }
+
+  @Override
+  public CompletableFuture<Void> closeStream() {
+    return operationResponse.closeStream();
+  }
+
+  @Override
+  public boolean isClosed() {
+    return operationResponse.isClosed();
+  }
+}

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

@@ -34,6 +34,8 @@
 import software.amazon.awssdk.aws.greengrass.model.ConfigurationValidityReport;
 import software.amazon.awssdk.aws.greengrass.model.ConfigurationValidityStatus;
 import software.amazon.awssdk.aws.greengrass.model.ConflictError;
+import software.amazon.awssdk.aws.greengrass.model.ConnectionStatus;
+import software.amazon.awssdk.aws.greengrass.model.ConnectionStatusEvent;
 import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordRequest;
 import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordResponse;
 import software.amazon.awssdk.aws.greengrass.model.CreateLocalDeploymentRequest;
@@ -66,6 +68,7 @@
 import software.amazon.awssdk.aws.greengrass.model.InvalidCredentialError;
 import software.amazon.awssdk.aws.greengrass.model.InvalidRecipeDirectoryPathError;
 import software.amazon.awssdk.aws.greengrass.model.InvalidTokenError;
+import software.amazon.awssdk.aws.greengrass.model.IoTCoreConnectionStatusEvent;
 import software.amazon.awssdk.aws.greengrass.model.IoTCoreMessage;
 import software.amazon.awssdk.aws.greengrass.model.JsonMessage;
 import software.amazon.awssdk.aws.greengrass.model.LifecycleState;
@@ -115,6 +118,8 @@
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesResponse;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateResponse;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusRequest;
+import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreConnectionStatusResponse;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreResponse;
 import software.amazon.awssdk.aws.greengrass.model.SubscribeToTopicRequest;
@@ -262,6 +267,10 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
 
   private static final SubscribeToIoTCoreOperationContext _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT = new SubscribeToIoTCoreOperationContext();
 
+  public static final String SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS = SERVICE_NAMESPACE + "#" + "SubscribeToIoTCoreConnectionStatus";
+
+  private static final SubscribeToIoTCoreConnectionStatusOperationContext _SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS_OPERATION_CONTEXT = new SubscribeToIoTCoreConnectionStatusOperationContext();
+
   public static final String SUBSCRIBE_TO_TOPIC = SERVICE_NAMESPACE + "#" + "SubscribeToTopic";
 
   private static final SubscribeToTopicOperationContext _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT = new SubscribeToTopicOperationContext();
@@ -345,6 +354,8 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
     SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_CONFIGURATION_UPDATE);
     SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_IOT_CORE, _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT);
     SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_IOT_CORE);
+    SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS, _SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS_OPERATION_CONTEXT);
+    SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS);
     SERVICE_OPERATION_MODEL_MAP.put(SUBSCRIBE_TO_TOPIC, _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT);
     SERVICE_OPERATION_SET.add(SUBSCRIBE_TO_TOPIC);
     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 {
     SERVICE_OBJECT_MODEL_MAP.put(ConfigurationValidityReport.APPLICATION_MODEL_TYPE, ConfigurationValidityReport.class);
     SERVICE_OBJECT_MODEL_MAP.put(ConfigurationValidityStatus.APPLICATION_MODEL_TYPE, ConfigurationValidityStatus.class);
     SERVICE_OBJECT_MODEL_MAP.put(ConflictError.APPLICATION_MODEL_TYPE, ConflictError.class);
+    SERVICE_OBJECT_MODEL_MAP.put(ConnectionStatus.APPLICATION_MODEL_TYPE, ConnectionStatus.class);
+    SERVICE_OBJECT_MODEL_MAP.put(ConnectionStatusEvent.APPLICATION_MODEL_TYPE, ConnectionStatusEvent.class);
     SERVICE_OBJECT_MODEL_MAP.put(CreateDebugPasswordRequest.APPLICATION_MODEL_TYPE, CreateDebugPasswordRequest.class);
     SERVICE_OBJECT_MODEL_MAP.put(CreateDebugPasswordResponse.APPLICATION_MODEL_TYPE, CreateDebugPasswordResponse.class);
     SERVICE_OBJECT_MODEL_MAP.put(CreateLocalDeploymentRequest.APPLICATION_MODEL_TYPE, CreateLocalDeploymentRequest.class);
@@ -409,6 +422,7 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
     SERVICE_OBJECT_MODEL_MAP.put(InvalidCredentialError.APPLICATION_MODEL_TYPE, InvalidCredentialError.class);
     SERVICE_OBJECT_MODEL_MAP.put(InvalidRecipeDirectoryPathError.APPLICATION_MODEL_TYPE, InvalidRecipeDirectoryPathError.class);
     SERVICE_OBJECT_MODEL_MAP.put(InvalidTokenError.APPLICATION_MODEL_TYPE, InvalidTokenError.class);
+    SERVICE_OBJECT_MODEL_MAP.put(IoTCoreConnectionStatusEvent.APPLICATION_MODEL_TYPE, IoTCoreConnectionStatusEvent.class);
     SERVICE_OBJECT_MODEL_MAP.put(IoTCoreMessage.APPLICATION_MODEL_TYPE, IoTCoreMessage.class);
     SERVICE_OBJECT_MODEL_MAP.put(JsonMessage.APPLICATION_MODEL_TYPE, JsonMessage.class);
     SERVICE_OBJECT_MODEL_MAP.put(LifecycleState.APPLICATION_MODEL_TYPE, LifecycleState.class);
@@ -458,6 +472,8 @@ public class GreengrassCoreIPCServiceModel extends EventStreamRPCServiceModel {
     SERVICE_OBJECT_MODEL_MAP.put(SubscribeToComponentUpdatesResponse.APPLICATION_MODEL_TYPE, SubscribeToComponentUpdatesResponse.class);
     SERVICE_OBJECT_MODEL_MAP.put(SubscribeToConfigurationUpdateRequest.APPLICATION_MODEL_TYPE, SubscribeToConfigurationUpdateRequest.class);
     SERVICE_OBJECT_MODEL_MAP.put(SubscribeToConfigurationUpdateResponse.APPLICATION_MODEL_TYPE, SubscribeToConfigurationUpdateResponse.class);
+    SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreConnectionStatusRequest.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreConnectionStatusRequest.class);
+    SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreConnectionStatusResponse.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreConnectionStatusResponse.class);
     SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreRequest.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreRequest.class);
     SERVICE_OBJECT_MODEL_MAP.put(SubscribeToIoTCoreResponse.APPLICATION_MODEL_TYPE, SubscribeToIoTCoreResponse.class);
     SERVICE_OBJECT_MODEL_MAP.put(SubscribeToTopicRequest.APPLICATION_MODEL_TYPE, SubscribeToTopicRequest.class);
@@ -607,6 +623,11 @@ public static SubscribeToIoTCoreOperationContext getSubscribeToIoTCoreModelConte
     return _SUBSCRIBE_TO_IOT_CORE_OPERATION_CONTEXT;
   }
 
+  public static SubscribeToIoTCoreConnectionStatusOperationContext getSubscribeToIoTCoreConnectionStatusModelContext(
+      ) {
+    return _SUBSCRIBE_TO_IOT_CORE_CONNECTION_STATUS_OPERATION_CONTEXT;
+  }
+
   public static SubscribeToTopicOperationContext getSubscribeToTopicModelContext() {
     return _SUBSCRIBE_TO_TOPIC_OPERATION_CONTEXT;
   }