Method Details

• submitMessage

  <T extends AbstractConfiguration<?>> ClusterManagementRealizationResult submitMessage(T configMessage, CommandType command)

  Submit a message with a specific command. This supports the ClusterManagementService.create(T) and ClusterManagementService.delete(T) commands.

  Type Parameters:

  T - configuration object which extends AbstractConfiguration

  Parameters:

  configMessage - configuration object

  command - the command to use

  Returns:

  ClusterManagementRealizationResult

• submitMessageForList

  <T extends AbstractConfiguration<R>, R extends RuntimeInfo> ClusterManagementListResult<T,R> submitMessageForList(T configMessage)

  Submit a message with a specific command which returns a list result. This supports the ClusterManagementService.list(AbstractConfiguration) command.

  Type Parameters:

  T - configuration object which extends AbstractConfiguration

  R - the type of the corresponding runtime information

  Parameters:

  configMessage - configuration object

  Returns:

  ClusterManagementListResult

• submitMessageForGet

  <T extends AbstractConfiguration<R>, R extends RuntimeInfo> ClusterManagementGetResult<T,R> submitMessageForGet(T configMessage)

  Submit a message with a specific command which returns a single result. This supports the ClusterManagementService.get(T) command.

  Type Parameters:

  T - configuration object which extends AbstractConfiguration

  R - the type of the corresponding runtime information

  Parameters:

  configMessage - configuration object

  Returns:

  ClusterManagementGetResult

• submitMessageForListOperation

  <A extends ClusterManagementOperation<V>, V extends OperationResult> ClusterManagementListOperationsResult<A,V> submitMessageForListOperation(A opType)

  Submit a message for a specific command which returns a list result of operations in progress. This supports the ClusterManagementService.list(ClusterManagementOperation) command.

  Type Parameters:

  A - operation of type ClusterManagementOperation

  V - result of type OperationResult

  Parameters:

  opType - the operation for which a message should be submitted

  Returns:

  ClusterManagementListResult

• submitMessageForGetOperation

  <A extends ClusterManagementOperation<V>, V extends OperationResult> ClusterManagementOperationResult<A,V> submitMessageForGetOperation(A opType, String operationId)

  Submit a message for a specific command which returns a single operation in progress. This supports the ClusterManagementService.get(AbstractConfiguration) command.

  Type Parameters:

  A - operation of type ClusterManagementOperation

  V - result of type OperationResult

  Parameters:

  opType - the operation for which a message should be submitted

  operationId - the identifier of the operation

  Returns:

  ClusterManagementListResult

• submitMessageForStart

  <A extends ClusterManagementOperation<V>, V extends OperationResult> ClusterManagementOperationResult<A,V> submitMessageForStart(A op)

  Submit a message to start a specific command. This supports the ClusterManagementService.start(ClusterManagementOperation) command.

  Type Parameters:

  A - operation of type ClusterManagementOperation

  V - result of type OperationResult

  Parameters:

  op - the operation for which a message should be submitted

  Returns:

  ClusterManagementListResult

• isConnected

  boolean isConnected()

  Indicate whether this transport is currently connected

  Returns:

  boolean indicating whether connected

• configureConnection

  void configureConnection(ConnectionConfig connectionConfig)

  Configure the transport with using connectionConfig.

  Parameters:

  connectionConfig - ConnectionConfig holding connection configuration information.

• close

  void close()

  Close the transport.