/* * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. * A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ /* * Do not modify this file. This file is generated from the mq-2017-11-27.normal.json service model. */ using System; using System.Runtime.ExceptionServices; using System.Threading; using System.Threading.Tasks; using System.Collections.Generic; using System.Net; using Amazon.MQ.Model; using Amazon.MQ.Model.Internal.MarshallTransformations; using Amazon.MQ.Internal; using Amazon.Runtime; using Amazon.Runtime.Internal; using Amazon.Runtime.Internal.Auth; using Amazon.Runtime.Internal.Transform; namespace Amazon.MQ { /// /// Implementation for accessing MQ /// /// Amazon MQ is a managed message broker service for Apache ActiveMQ and RabbitMQ that /// makes it easy to set up and operate message brokers in the cloud. A message broker /// allows software applications and components to communicate using various programming /// languages, operating systems, and formal messaging protocols. /// public partial class AmazonMQClient : AmazonServiceClient, IAmazonMQ { private static IServiceMetadata serviceMetadata = new AmazonMQMetadata(); private IMQPaginatorFactory _paginators; /// /// Paginators for the service /// public IMQPaginatorFactory Paginators { get { if (this._paginators == null) { this._paginators = new MQPaginatorFactory(this); } return this._paginators; } } #region Constructors /// /// Constructs AmazonMQClient with the credentials loaded from the application's /// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance. /// /// Example App.config with credentials set. /// /// <?xml version="1.0" encoding="utf-8" ?> /// <configuration> /// <appSettings> /// <add key="AWSProfileName" value="AWS Default"/> /// </appSettings> /// </configuration> /// /// /// public AmazonMQClient() : base(FallbackCredentialsFactory.GetCredentials(), new AmazonMQConfig()) { } /// /// Constructs AmazonMQClient with the credentials loaded from the application's /// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance. /// /// Example App.config with credentials set. /// /// <?xml version="1.0" encoding="utf-8" ?> /// <configuration> /// <appSettings> /// <add key="AWSProfileName" value="AWS Default"/> /// </appSettings> /// </configuration> /// /// /// /// The region to connect. public AmazonMQClient(RegionEndpoint region) : base(FallbackCredentialsFactory.GetCredentials(), new AmazonMQConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonMQClient with the credentials loaded from the application's /// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance. /// /// Example App.config with credentials set. /// /// <?xml version="1.0" encoding="utf-8" ?> /// <configuration> /// <appSettings> /// <add key="AWSProfileName" value="AWS Default"/> /// </appSettings> /// </configuration> /// /// /// /// The AmazonMQClient Configuration Object public AmazonMQClient(AmazonMQConfig config) : base(FallbackCredentialsFactory.GetCredentials(config), config){} /// /// Constructs AmazonMQClient with AWS Credentials /// /// AWS Credentials public AmazonMQClient(AWSCredentials credentials) : this(credentials, new AmazonMQConfig()) { } /// /// Constructs AmazonMQClient with AWS Credentials /// /// AWS Credentials /// The region to connect. public AmazonMQClient(AWSCredentials credentials, RegionEndpoint region) : this(credentials, new AmazonMQConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonMQClient with AWS Credentials and an /// AmazonMQClient Configuration object. /// /// AWS Credentials /// The AmazonMQClient Configuration Object public AmazonMQClient(AWSCredentials credentials, AmazonMQConfig clientConfig) : base(credentials, clientConfig) { } /// /// Constructs AmazonMQClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key public AmazonMQClient(string awsAccessKeyId, string awsSecretAccessKey) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonMQConfig()) { } /// /// Constructs AmazonMQClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// The region to connect. public AmazonMQClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonMQConfig() {RegionEndpoint=region}) { } /// /// Constructs AmazonMQClient with AWS Access Key ID, AWS Secret Key and an /// AmazonMQClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// The AmazonMQClient Configuration Object public AmazonMQClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonMQConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, clientConfig) { } /// /// Constructs AmazonMQClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token public AmazonMQClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonMQConfig()) { } /// /// Constructs AmazonMQClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token /// The region to connect. public AmazonMQClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonMQConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonMQClient with AWS Access Key ID, AWS Secret Key and an /// AmazonMQClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token /// The AmazonMQClient Configuration Object public AmazonMQClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonMQConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig) { } #endregion #region Overrides /// /// Creates the signer for the service. /// protected override AbstractAWSSigner CreateSigner() { return new AWS4Signer(); } /// /// Customize the pipeline /// /// protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline) { pipeline.RemoveHandler(); pipeline.AddHandlerAfter(new AmazonMQEndpointResolver()); } /// /// Capture metadata for the service. /// protected override IServiceMetadata ServiceMetadata { get { return serviceMetadata; } } #endregion #region Dispose /// /// Disposes the service client. /// protected override void Dispose(bool disposing) { base.Dispose(disposing); } #endregion #region CreateBroker /// /// Creates a broker. Note: This API is asynchronous. /// /// /// /// To create a broker, you must either use the AmazonMQFullAccess IAM policy or include /// the following EC2 permissions in your IAM policy. /// ///
  • /// /// ec2:CreateNetworkInterface /// /// /// /// This permission is required to allow Amazon MQ to create an elastic network interface /// (ENI) on behalf of your account. /// ///
  • /// /// ec2:CreateNetworkInterfacePermission /// /// /// /// This permission is required to attach the ENI to the broker instance. /// ///
  • /// /// ec2:DeleteNetworkInterface /// ///
  • /// /// ec2:DeleteNetworkInterfacePermission /// ///
  • /// /// ec2:DetachNetworkInterface /// ///
  • /// /// ec2:DescribeInternetGateways /// ///
  • /// /// ec2:DescribeNetworkInterfaces /// ///
  • /// /// ec2:DescribeNetworkInterfacePermissions /// ///
  • /// /// ec2:DescribeRouteTables /// ///
  • /// /// ec2:DescribeSecurityGroups /// ///
  • /// /// ec2:DescribeSubnets /// ///
  • /// /// ec2:DescribeVpcs /// ///
/// /// For more information, see Create /// an IAM User and Get Your Amazon Web Services Credentials and Never /// Modify or Delete the Amazon MQ Elastic Network Interface in the Amazon MQ Developer /// Guide. /// ///
/// Container for the necessary parameters to execute the CreateBroker service method. /// /// The response from the CreateBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateBroker Operation public virtual CreateBrokerResponse CreateBroker(CreateBrokerRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateBrokerResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Creates a broker. Note: This API is asynchronous. /// /// /// /// To create a broker, you must either use the AmazonMQFullAccess IAM policy or include /// the following EC2 permissions in your IAM policy. /// ///
  • /// /// ec2:CreateNetworkInterface /// /// /// /// This permission is required to allow Amazon MQ to create an elastic network interface /// (ENI) on behalf of your account. /// ///
  • /// /// ec2:CreateNetworkInterfacePermission /// /// /// /// This permission is required to attach the ENI to the broker instance. /// ///
  • /// /// ec2:DeleteNetworkInterface /// ///
  • /// /// ec2:DeleteNetworkInterfacePermission /// ///
  • /// /// ec2:DetachNetworkInterface /// ///
  • /// /// ec2:DescribeInternetGateways /// ///
  • /// /// ec2:DescribeNetworkInterfaces /// ///
  • /// /// ec2:DescribeNetworkInterfacePermissions /// ///
  • /// /// ec2:DescribeRouteTables /// ///
  • /// /// ec2:DescribeSecurityGroups /// ///
  • /// /// ec2:DescribeSubnets /// ///
  • /// /// ec2:DescribeVpcs /// ///
/// /// For more information, see Create /// an IAM User and Get Your Amazon Web Services Credentials and Never /// Modify or Delete the Amazon MQ Elastic Network Interface in the Amazon MQ Developer /// Guide. /// ///
/// Container for the necessary parameters to execute the CreateBroker service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CreateBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateBroker Operation public virtual Task CreateBrokerAsync(CreateBrokerRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CreateBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateBrokerResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region CreateConfiguration /// /// Creates a new configuration for the specified configuration name. Amazon MQ uses the /// default configuration (the engine type and version). /// /// Container for the necessary parameters to execute the CreateConfiguration service method. /// /// The response from the CreateConfiguration service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateConfiguration Operation public virtual CreateConfigurationResponse CreateConfiguration(CreateConfigurationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateConfigurationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Creates a new configuration for the specified configuration name. Amazon MQ uses the /// default configuration (the engine type and version). /// /// Container for the necessary parameters to execute the CreateConfiguration service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CreateConfiguration service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateConfiguration Operation public virtual Task CreateConfigurationAsync(CreateConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CreateConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateConfigurationResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region CreateTags /// /// Add a tag to a resource. /// /// Container for the necessary parameters to execute the CreateTags service method. /// /// The response from the CreateTags service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateTags Operation public virtual CreateTagsResponse CreateTags(CreateTagsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateTagsRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateTagsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Add a tag to a resource. /// /// Container for the necessary parameters to execute the CreateTags service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CreateTags service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateTags Operation public virtual Task CreateTagsAsync(CreateTagsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CreateTagsRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateTagsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region CreateUser /// /// Creates an ActiveMQ user. /// /// /// /// Do not add personally identifiable information (PII) or other confidential or sensitive /// information in broker usernames. Broker usernames are accessible to other Amazon Web /// Services services, including CloudWatch Logs. Broker usernames are not intended to /// be used for private or sensitive data. /// /// /// /// Container for the necessary parameters to execute the CreateUser service method. /// /// The response from the CreateUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateUser Operation public virtual CreateUserResponse CreateUser(CreateUserRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateUserRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateUserResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Creates an ActiveMQ user. /// /// /// /// Do not add personally identifiable information (PII) or other confidential or sensitive /// information in broker usernames. Broker usernames are accessible to other Amazon Web /// Services services, including CloudWatch Logs. Broker usernames are not intended to /// be used for private or sensitive data. /// /// /// /// Container for the necessary parameters to execute the CreateUser service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CreateUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for CreateUser Operation public virtual Task CreateUserAsync(CreateUserRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CreateUserRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateUserResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DeleteBroker /// /// Deletes a broker. Note: This API is asynchronous. /// /// Container for the necessary parameters to execute the DeleteBroker service method. /// /// The response from the DeleteBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DeleteBroker Operation public virtual DeleteBrokerResponse DeleteBroker(DeleteBrokerRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteBrokerResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Deletes a broker. Note: This API is asynchronous. /// /// Container for the necessary parameters to execute the DeleteBroker service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DeleteBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DeleteBroker Operation public virtual Task DeleteBrokerAsync(DeleteBrokerRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteBrokerResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DeleteTags /// /// Removes a tag from a resource. /// /// Container for the necessary parameters to execute the DeleteTags service method. /// /// The response from the DeleteTags service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DeleteTags Operation public virtual DeleteTagsResponse DeleteTags(DeleteTagsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteTagsRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteTagsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Removes a tag from a resource. /// /// Container for the necessary parameters to execute the DeleteTags service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DeleteTags service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DeleteTags Operation public virtual Task DeleteTagsAsync(DeleteTagsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteTagsRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteTagsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DeleteUser /// /// Deletes an ActiveMQ user. /// /// Container for the necessary parameters to execute the DeleteUser service method. /// /// The response from the DeleteUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DeleteUser Operation public virtual DeleteUserResponse DeleteUser(DeleteUserRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteUserRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteUserResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Deletes an ActiveMQ user. /// /// Container for the necessary parameters to execute the DeleteUser service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DeleteUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DeleteUser Operation public virtual Task DeleteUserAsync(DeleteUserRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteUserRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteUserResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeBroker /// /// Returns information about the specified broker. /// /// Container for the necessary parameters to execute the DescribeBroker service method. /// /// The response from the DescribeBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeBroker Operation public virtual DescribeBrokerResponse DescribeBroker(DescribeBrokerRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeBrokerResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns information about the specified broker. /// /// Container for the necessary parameters to execute the DescribeBroker service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeBroker Operation public virtual Task DescribeBrokerAsync(DescribeBrokerRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeBrokerResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeBrokerEngineTypes /// /// Describe available engine types and versions. /// /// Container for the necessary parameters to execute the DescribeBrokerEngineTypes service method. /// /// The response from the DescribeBrokerEngineTypes service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeBrokerEngineTypes Operation public virtual DescribeBrokerEngineTypesResponse DescribeBrokerEngineTypes(DescribeBrokerEngineTypesRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeBrokerEngineTypesRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeBrokerEngineTypesResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Describe available engine types and versions. /// /// Container for the necessary parameters to execute the DescribeBrokerEngineTypes service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeBrokerEngineTypes service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeBrokerEngineTypes Operation public virtual Task DescribeBrokerEngineTypesAsync(DescribeBrokerEngineTypesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeBrokerEngineTypesRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeBrokerEngineTypesResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeBrokerInstanceOptions /// /// Describe available broker instance options. /// /// Container for the necessary parameters to execute the DescribeBrokerInstanceOptions service method. /// /// The response from the DescribeBrokerInstanceOptions service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeBrokerInstanceOptions Operation public virtual DescribeBrokerInstanceOptionsResponse DescribeBrokerInstanceOptions(DescribeBrokerInstanceOptionsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeBrokerInstanceOptionsRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeBrokerInstanceOptionsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Describe available broker instance options. /// /// Container for the necessary parameters to execute the DescribeBrokerInstanceOptions service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeBrokerInstanceOptions service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeBrokerInstanceOptions Operation public virtual Task DescribeBrokerInstanceOptionsAsync(DescribeBrokerInstanceOptionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeBrokerInstanceOptionsRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeBrokerInstanceOptionsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeConfiguration /// /// Returns information about the specified configuration. /// /// Container for the necessary parameters to execute the DescribeConfiguration service method. /// /// The response from the DescribeConfiguration service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeConfiguration Operation public virtual DescribeConfigurationResponse DescribeConfiguration(DescribeConfigurationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeConfigurationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns information about the specified configuration. /// /// Container for the necessary parameters to execute the DescribeConfiguration service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeConfiguration service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeConfiguration Operation public virtual Task DescribeConfigurationAsync(DescribeConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeConfigurationResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeConfigurationRevision /// /// Returns the specified configuration revision for the specified configuration. /// /// Container for the necessary parameters to execute the DescribeConfigurationRevision service method. /// /// The response from the DescribeConfigurationRevision service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeConfigurationRevision Operation public virtual DescribeConfigurationRevisionResponse DescribeConfigurationRevision(DescribeConfigurationRevisionRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeConfigurationRevisionRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeConfigurationRevisionResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns the specified configuration revision for the specified configuration. /// /// Container for the necessary parameters to execute the DescribeConfigurationRevision service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeConfigurationRevision service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeConfigurationRevision Operation public virtual Task DescribeConfigurationRevisionAsync(DescribeConfigurationRevisionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeConfigurationRevisionRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeConfigurationRevisionResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeUser /// /// Returns information about an ActiveMQ user. /// /// Container for the necessary parameters to execute the DescribeUser service method. /// /// The response from the DescribeUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeUser Operation public virtual DescribeUserResponse DescribeUser(DescribeUserRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeUserRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeUserResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns information about an ActiveMQ user. /// /// Container for the necessary parameters to execute the DescribeUser service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for DescribeUser Operation public virtual Task DescribeUserAsync(DescribeUserRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeUserRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeUserResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListBrokers /// /// Returns a list of all brokers. /// /// Container for the necessary parameters to execute the ListBrokers service method. /// /// The response from the ListBrokers service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListBrokers Operation public virtual ListBrokersResponse ListBrokers(ListBrokersRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListBrokersRequestMarshaller.Instance; options.ResponseUnmarshaller = ListBrokersResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns a list of all brokers. /// /// Container for the necessary parameters to execute the ListBrokers service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListBrokers service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListBrokers Operation public virtual Task ListBrokersAsync(ListBrokersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListBrokersRequestMarshaller.Instance; options.ResponseUnmarshaller = ListBrokersResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListConfigurationRevisions /// /// Returns a list of all revisions for the specified configuration. /// /// Container for the necessary parameters to execute the ListConfigurationRevisions service method. /// /// The response from the ListConfigurationRevisions service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListConfigurationRevisions Operation public virtual ListConfigurationRevisionsResponse ListConfigurationRevisions(ListConfigurationRevisionsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListConfigurationRevisionsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListConfigurationRevisionsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns a list of all revisions for the specified configuration. /// /// Container for the necessary parameters to execute the ListConfigurationRevisions service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListConfigurationRevisions service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListConfigurationRevisions Operation public virtual Task ListConfigurationRevisionsAsync(ListConfigurationRevisionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListConfigurationRevisionsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListConfigurationRevisionsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListConfigurations /// /// Returns a list of all configurations. /// /// Container for the necessary parameters to execute the ListConfigurations service method. /// /// The response from the ListConfigurations service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListConfigurations Operation public virtual ListConfigurationsResponse ListConfigurations(ListConfigurationsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListConfigurationsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListConfigurationsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns a list of all configurations. /// /// Container for the necessary parameters to execute the ListConfigurations service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListConfigurations service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListConfigurations Operation public virtual Task ListConfigurationsAsync(ListConfigurationsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListConfigurationsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListConfigurationsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListTags /// /// Lists tags for a resource. /// /// Container for the necessary parameters to execute the ListTags service method. /// /// The response from the ListTags service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListTags Operation public virtual ListTagsResponse ListTags(ListTagsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListTagsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListTagsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Lists tags for a resource. /// /// Container for the necessary parameters to execute the ListTags service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListTags service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListTags Operation public virtual Task ListTagsAsync(ListTagsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListTagsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListTagsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListUsers /// /// Returns a list of all ActiveMQ users. /// /// Container for the necessary parameters to execute the ListUsers service method. /// /// The response from the ListUsers service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListUsers Operation public virtual ListUsersResponse ListUsers(ListUsersRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListUsersRequestMarshaller.Instance; options.ResponseUnmarshaller = ListUsersResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Returns a list of all ActiveMQ users. /// /// Container for the necessary parameters to execute the ListUsers service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListUsers service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for ListUsers Operation public virtual Task ListUsersAsync(ListUsersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListUsersRequestMarshaller.Instance; options.ResponseUnmarshaller = ListUsersResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region Promote /// /// Promotes a data replication replica broker to the primary broker role. /// /// Container for the necessary parameters to execute the Promote service method. /// /// The response from the Promote service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for Promote Operation public virtual PromoteResponse Promote(PromoteRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = PromoteRequestMarshaller.Instance; options.ResponseUnmarshaller = PromoteResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Promotes a data replication replica broker to the primary broker role. /// /// Container for the necessary parameters to execute the Promote service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the Promote service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for Promote Operation public virtual Task PromoteAsync(PromoteRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = PromoteRequestMarshaller.Instance; options.ResponseUnmarshaller = PromoteResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region RebootBroker /// /// Reboots a broker. Note: This API is asynchronous. /// /// Container for the necessary parameters to execute the RebootBroker service method. /// /// The response from the RebootBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for RebootBroker Operation public virtual RebootBrokerResponse RebootBroker(RebootBrokerRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = RebootBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = RebootBrokerResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Reboots a broker. Note: This API is asynchronous. /// /// Container for the necessary parameters to execute the RebootBroker service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the RebootBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for RebootBroker Operation public virtual Task RebootBrokerAsync(RebootBrokerRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = RebootBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = RebootBrokerResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region UpdateBroker /// /// Adds a pending configuration change to a broker. /// /// Container for the necessary parameters to execute the UpdateBroker service method. /// /// The response from the UpdateBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for UpdateBroker Operation public virtual UpdateBrokerResponse UpdateBroker(UpdateBrokerRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateBrokerResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Adds a pending configuration change to a broker. /// /// Container for the necessary parameters to execute the UpdateBroker service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the UpdateBroker service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for UpdateBroker Operation public virtual Task UpdateBrokerAsync(UpdateBrokerRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateBrokerRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateBrokerResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region UpdateConfiguration /// /// Updates the specified configuration. /// /// Container for the necessary parameters to execute the UpdateConfiguration service method. /// /// The response from the UpdateConfiguration service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for UpdateConfiguration Operation public virtual UpdateConfigurationResponse UpdateConfiguration(UpdateConfigurationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateConfigurationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Updates the specified configuration. /// /// Container for the necessary parameters to execute the UpdateConfiguration service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the UpdateConfiguration service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for UpdateConfiguration Operation public virtual Task UpdateConfigurationAsync(UpdateConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateConfigurationResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region UpdateUser /// /// Updates the information for an ActiveMQ user. /// /// Container for the necessary parameters to execute the UpdateUser service method. /// /// The response from the UpdateUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for UpdateUser Operation public virtual UpdateUserResponse UpdateUser(UpdateUserRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateUserRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateUserResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Updates the information for an ActiveMQ user. /// /// Container for the necessary parameters to execute the UpdateUser service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the UpdateUser service method, as returned by MQ. /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// /// Returns information about an error. /// /// REST API Reference for UpdateUser Operation public virtual Task UpdateUserAsync(UpdateUserRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateUserRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateUserResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion } }