Interface MqClient
- All Superinterfaces:
AutoCloseable,AwsClient,SdkAutoCloseable,SdkClient
builder() method.
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.
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StringValue for looking up the service's metadata from theServiceMetadataProvider.static final String -
Method Summary
Modifier and TypeMethodDescriptionstatic MqClientBuilderbuilder()Create a builder that can be used to configure and create aMqClient.static MqClientcreate()Create aMqClientwith the region loaded from theDefaultAwsRegionProviderChainand credentials loaded from theDefaultCredentialsProvider.default CreateBrokerResponsecreateBroker(Consumer<CreateBrokerRequest.Builder> createBrokerRequest) Creates a broker.default CreateBrokerResponsecreateBroker(CreateBrokerRequest createBrokerRequest) Creates a broker.default CreateConfigurationResponsecreateConfiguration(Consumer<CreateConfigurationRequest.Builder> createConfigurationRequest) Creates a new configuration for the specified configuration name.default CreateConfigurationResponsecreateConfiguration(CreateConfigurationRequest createConfigurationRequest) Creates a new configuration for the specified configuration name.default CreateTagsResponsecreateTags(Consumer<CreateTagsRequest.Builder> createTagsRequest) Add a tag to a resource.default CreateTagsResponsecreateTags(CreateTagsRequest createTagsRequest) Add a tag to a resource.default CreateUserResponsecreateUser(Consumer<CreateUserRequest.Builder> createUserRequest) Creates an ActiveMQ user.default CreateUserResponsecreateUser(CreateUserRequest createUserRequest) Creates an ActiveMQ user.default DeleteBrokerResponsedeleteBroker(Consumer<DeleteBrokerRequest.Builder> deleteBrokerRequest) Deletes a broker.default DeleteBrokerResponsedeleteBroker(DeleteBrokerRequest deleteBrokerRequest) Deletes a broker.default DeleteTagsResponsedeleteTags(Consumer<DeleteTagsRequest.Builder> deleteTagsRequest) Removes a tag from a resource.default DeleteTagsResponsedeleteTags(DeleteTagsRequest deleteTagsRequest) Removes a tag from a resource.default DeleteUserResponsedeleteUser(Consumer<DeleteUserRequest.Builder> deleteUserRequest) Deletes an ActiveMQ user.default DeleteUserResponsedeleteUser(DeleteUserRequest deleteUserRequest) Deletes an ActiveMQ user.default DescribeBrokerResponsedescribeBroker(Consumer<DescribeBrokerRequest.Builder> describeBrokerRequest) Returns information about the specified broker.default DescribeBrokerResponsedescribeBroker(DescribeBrokerRequest describeBrokerRequest) Returns information about the specified broker.describeBrokerEngineTypes(Consumer<DescribeBrokerEngineTypesRequest.Builder> describeBrokerEngineTypesRequest) Describe available engine types and versions.describeBrokerEngineTypes(DescribeBrokerEngineTypesRequest describeBrokerEngineTypesRequest) Describe available engine types and versions.describeBrokerInstanceOptions(Consumer<DescribeBrokerInstanceOptionsRequest.Builder> describeBrokerInstanceOptionsRequest) Describe available broker instance options.describeBrokerInstanceOptions(DescribeBrokerInstanceOptionsRequest describeBrokerInstanceOptionsRequest) Describe available broker instance options.default DescribeConfigurationResponsedescribeConfiguration(Consumer<DescribeConfigurationRequest.Builder> describeConfigurationRequest) Returns information about the specified configuration.default DescribeConfigurationResponsedescribeConfiguration(DescribeConfigurationRequest describeConfigurationRequest) Returns information about the specified configuration.describeConfigurationRevision(Consumer<DescribeConfigurationRevisionRequest.Builder> describeConfigurationRevisionRequest) Returns the specified configuration revision for the specified configuration.describeConfigurationRevision(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest) Returns the specified configuration revision for the specified configuration.default DescribeUserResponsedescribeUser(Consumer<DescribeUserRequest.Builder> describeUserRequest) Returns information about an ActiveMQ user.default DescribeUserResponsedescribeUser(DescribeUserRequest describeUserRequest) Returns information about an ActiveMQ user.default ListBrokersResponseReturns a list of all brokers.default ListBrokersResponselistBrokers(Consumer<ListBrokersRequest.Builder> listBrokersRequest) Returns a list of all brokers.default ListBrokersResponselistBrokers(ListBrokersRequest listBrokersRequest) Returns a list of all brokers.default ListBrokersIterableThis is a variant oflistBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation.default ListBrokersIterablelistBrokersPaginator(Consumer<ListBrokersRequest.Builder> listBrokersRequest) This is a variant oflistBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation.default ListBrokersIterablelistBrokersPaginator(ListBrokersRequest listBrokersRequest) This is a variant oflistBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation.listConfigurationRevisions(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest) Returns a list of all revisions for the specified configuration.listConfigurationRevisions(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest) Returns a list of all revisions for the specified configuration.default ListConfigurationsResponseReturns a list of all configurations.default ListConfigurationsResponselistConfigurations(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest) Returns a list of all configurations.default ListConfigurationsResponselistConfigurations(ListConfigurationsRequest listConfigurationsRequest) Returns a list of all configurations.default ListTagsResponselistTags(Consumer<ListTagsRequest.Builder> listTagsRequest) Lists tags for a resource.default ListTagsResponselistTags(ListTagsRequest listTagsRequest) Lists tags for a resource.default ListUsersResponselistUsers(Consumer<ListUsersRequest.Builder> listUsersRequest) Returns a list of all ActiveMQ users.default ListUsersResponselistUsers(ListUsersRequest listUsersRequest) Returns a list of all ActiveMQ users.default PromoteResponsepromote(Consumer<PromoteRequest.Builder> promoteRequest) Promotes a data replication replica broker to the primary broker role.default PromoteResponsepromote(PromoteRequest promoteRequest) Promotes a data replication replica broker to the primary broker role.default RebootBrokerResponserebootBroker(Consumer<RebootBrokerRequest.Builder> rebootBrokerRequest) Reboots a broker.default RebootBrokerResponserebootBroker(RebootBrokerRequest rebootBrokerRequest) Reboots a broker.default MqServiceClientConfigurationThe SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfigurationstatic ServiceMetadatadefault UpdateBrokerResponseupdateBroker(Consumer<UpdateBrokerRequest.Builder> updateBrokerRequest) Adds a pending configuration change to a broker.default UpdateBrokerResponseupdateBroker(UpdateBrokerRequest updateBrokerRequest) Adds a pending configuration change to a broker.default UpdateConfigurationResponseupdateConfiguration(Consumer<UpdateConfigurationRequest.Builder> updateConfigurationRequest) Updates the specified configuration.default UpdateConfigurationResponseupdateConfiguration(UpdateConfigurationRequest updateConfigurationRequest) Updates the specified configuration.default UpdateUserResponseupdateUser(Consumer<UpdateUserRequest.Builder> updateUserRequest) Updates the information for an ActiveMQ user.default UpdateUserResponseupdateUser(UpdateUserRequest updateUserRequest) Updates the information for an ActiveMQ user.Methods inherited from interface software.amazon.awssdk.utils.SdkAutoCloseable
closeMethods inherited from interface software.amazon.awssdk.core.SdkClient
serviceName
-
Field Details
-
SERVICE_NAME
- See Also:
-
SERVICE_METADATA_ID
Value for looking up the service's metadata from theServiceMetadataProvider.- See Also:
-
-
Method Details
-
createBroker
default CreateBrokerResponse createBroker(CreateBrokerRequest createBrokerRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException 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.
- Parameters:
createBrokerRequest- Creates a broker using the specified properties.- Returns:
- Result of the CreateBroker operation returned by the service.
- See Also:
-
-
createBroker
default CreateBrokerResponse createBroker(Consumer<CreateBrokerRequest.Builder> createBrokerRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException 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.
This is a convenience which creates an instance of the
CreateBrokerRequest.Builderavoiding the need to create one manually viaCreateBrokerRequest.builder()- Parameters:
createBrokerRequest- AConsumerthat will call methods onCreateBrokerRequest.Builderto create a request. Creates a broker using the specified properties.- Returns:
- Result of the CreateBroker operation returned by the service.
- See Also:
-
-
createConfiguration
default CreateConfigurationResponse createConfiguration(CreateConfigurationRequest createConfigurationRequest) throws BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Creates a new configuration for the specified configuration name. Amazon MQ uses the default configuration (the engine type and version).
- Parameters:
createConfigurationRequest- Creates a new configuration for the specified configuration name. Amazon MQ uses the default configuration (the engine type and version).- Returns:
- Result of the CreateConfiguration operation returned by the service.
- See Also:
-
createConfiguration
default CreateConfigurationResponse createConfiguration(Consumer<CreateConfigurationRequest.Builder> createConfigurationRequest) throws BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Creates a new configuration for the specified configuration name. Amazon MQ uses the default configuration (the engine type and version).
This is a convenience which creates an instance of the
CreateConfigurationRequest.Builderavoiding the need to create one manually viaCreateConfigurationRequest.builder()- Parameters:
createConfigurationRequest- AConsumerthat will call methods onCreateConfigurationRequest.Builderto create a request. Creates a new configuration for the specified configuration name. Amazon MQ uses the default configuration (the engine type and version).- Returns:
- Result of the CreateConfiguration operation returned by the service.
- See Also:
-
createTags
default CreateTagsResponse createTags(CreateTagsRequest createTagsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Add a tag to a resource.
- Parameters:
createTagsRequest- A map of the key-value pairs for the resource tag.- Returns:
- Result of the CreateTags operation returned by the service.
- See Also:
-
createTags
default CreateTagsResponse createTags(Consumer<CreateTagsRequest.Builder> createTagsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Add a tag to a resource.
This is a convenience which creates an instance of the
CreateTagsRequest.Builderavoiding the need to create one manually viaCreateTagsRequest.builder()- Parameters:
createTagsRequest- AConsumerthat will call methods onCreateTagsRequest.Builderto create a request. A map of the key-value pairs for the resource tag.- Returns:
- Result of the CreateTags operation returned by the service.
- See Also:
-
createUser
default CreateUserResponse createUser(CreateUserRequest createUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException 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.
- Parameters:
createUserRequest- Creates a new ActiveMQ user.- Returns:
- Result of the CreateUser operation returned by the service.
- See Also:
-
createUser
default CreateUserResponse createUser(Consumer<CreateUserRequest.Builder> createUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException 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.
This is a convenience which creates an instance of the
CreateUserRequest.Builderavoiding the need to create one manually viaCreateUserRequest.builder()- Parameters:
createUserRequest- AConsumerthat will call methods onCreateUserRequest.Builderto create a request. Creates a new ActiveMQ user.- Returns:
- Result of the CreateUser operation returned by the service.
- See Also:
-
deleteBroker
default DeleteBrokerResponse deleteBroker(DeleteBrokerRequest deleteBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Deletes a broker. Note: This API is asynchronous.
- Parameters:
deleteBrokerRequest-- Returns:
- Result of the DeleteBroker operation returned by the service.
- See Also:
-
deleteBroker
default DeleteBrokerResponse deleteBroker(Consumer<DeleteBrokerRequest.Builder> deleteBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Deletes a broker. Note: This API is asynchronous.
This is a convenience which creates an instance of the
DeleteBrokerRequest.Builderavoiding the need to create one manually viaDeleteBrokerRequest.builder()- Parameters:
deleteBrokerRequest- AConsumerthat will call methods onDeleteBrokerRequest.Builderto create a request.- Returns:
- Result of the DeleteBroker operation returned by the service.
- See Also:
-
deleteTags
default DeleteTagsResponse deleteTags(DeleteTagsRequest deleteTagsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Removes a tag from a resource.
- Parameters:
deleteTagsRequest-- Returns:
- Result of the DeleteTags operation returned by the service.
- See Also:
-
deleteTags
default DeleteTagsResponse deleteTags(Consumer<DeleteTagsRequest.Builder> deleteTagsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Removes a tag from a resource.
This is a convenience which creates an instance of the
DeleteTagsRequest.Builderavoiding the need to create one manually viaDeleteTagsRequest.builder()- Parameters:
deleteTagsRequest- AConsumerthat will call methods onDeleteTagsRequest.Builderto create a request.- Returns:
- Result of the DeleteTags operation returned by the service.
- See Also:
-
deleteUser
default DeleteUserResponse deleteUser(DeleteUserRequest deleteUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Deletes an ActiveMQ user.
- Parameters:
deleteUserRequest-- Returns:
- Result of the DeleteUser operation returned by the service.
- See Also:
-
deleteUser
default DeleteUserResponse deleteUser(Consumer<DeleteUserRequest.Builder> deleteUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Deletes an ActiveMQ user.
This is a convenience which creates an instance of the
DeleteUserRequest.Builderavoiding the need to create one manually viaDeleteUserRequest.builder()- Parameters:
deleteUserRequest- AConsumerthat will call methods onDeleteUserRequest.Builderto create a request.- Returns:
- Result of the DeleteUser operation returned by the service.
- See Also:
-
describeBroker
default DescribeBrokerResponse describeBroker(DescribeBrokerRequest describeBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns information about the specified broker.
- Parameters:
describeBrokerRequest-- Returns:
- Result of the DescribeBroker operation returned by the service.
- See Also:
-
describeBroker
default DescribeBrokerResponse describeBroker(Consumer<DescribeBrokerRequest.Builder> describeBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns information about the specified broker.
This is a convenience which creates an instance of the
DescribeBrokerRequest.Builderavoiding the need to create one manually viaDescribeBrokerRequest.builder()- Parameters:
describeBrokerRequest- AConsumerthat will call methods onDescribeBrokerRequest.Builderto create a request.- Returns:
- Result of the DescribeBroker operation returned by the service.
- See Also:
-
describeBrokerEngineTypes
default DescribeBrokerEngineTypesResponse describeBrokerEngineTypes(DescribeBrokerEngineTypesRequest describeBrokerEngineTypesRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Describe available engine types and versions.
- Parameters:
describeBrokerEngineTypesRequest-- Returns:
- Result of the DescribeBrokerEngineTypes operation returned by the service.
- See Also:
-
describeBrokerEngineTypes
default DescribeBrokerEngineTypesResponse describeBrokerEngineTypes(Consumer<DescribeBrokerEngineTypesRequest.Builder> describeBrokerEngineTypesRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Describe available engine types and versions.
This is a convenience which creates an instance of the
DescribeBrokerEngineTypesRequest.Builderavoiding the need to create one manually viaDescribeBrokerEngineTypesRequest.builder()- Parameters:
describeBrokerEngineTypesRequest- AConsumerthat will call methods onDescribeBrokerEngineTypesRequest.Builderto create a request.- Returns:
- Result of the DescribeBrokerEngineTypes operation returned by the service.
- See Also:
-
describeBrokerInstanceOptions
default DescribeBrokerInstanceOptionsResponse describeBrokerInstanceOptions(DescribeBrokerInstanceOptionsRequest describeBrokerInstanceOptionsRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Describe available broker instance options.
- Parameters:
describeBrokerInstanceOptionsRequest-- Returns:
- Result of the DescribeBrokerInstanceOptions operation returned by the service.
- See Also:
-
describeBrokerInstanceOptions
default DescribeBrokerInstanceOptionsResponse describeBrokerInstanceOptions(Consumer<DescribeBrokerInstanceOptionsRequest.Builder> describeBrokerInstanceOptionsRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Describe available broker instance options.
This is a convenience which creates an instance of the
DescribeBrokerInstanceOptionsRequest.Builderavoiding the need to create one manually viaDescribeBrokerInstanceOptionsRequest.builder()- Parameters:
describeBrokerInstanceOptionsRequest- AConsumerthat will call methods onDescribeBrokerInstanceOptionsRequest.Builderto create a request.- Returns:
- Result of the DescribeBrokerInstanceOptions operation returned by the service.
- See Also:
-
describeConfiguration
default DescribeConfigurationResponse describeConfiguration(DescribeConfigurationRequest describeConfigurationRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns information about the specified configuration.
- Parameters:
describeConfigurationRequest-- Returns:
- Result of the DescribeConfiguration operation returned by the service.
- See Also:
-
describeConfiguration
default DescribeConfigurationResponse describeConfiguration(Consumer<DescribeConfigurationRequest.Builder> describeConfigurationRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns information about the specified configuration.
This is a convenience which creates an instance of the
DescribeConfigurationRequest.Builderavoiding the need to create one manually viaDescribeConfigurationRequest.builder()- Parameters:
describeConfigurationRequest- AConsumerthat will call methods onDescribeConfigurationRequest.Builderto create a request.- Returns:
- Result of the DescribeConfiguration operation returned by the service.
- See Also:
-
describeConfigurationRevision
default DescribeConfigurationRevisionResponse describeConfigurationRevision(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns the specified configuration revision for the specified configuration.
- Parameters:
describeConfigurationRevisionRequest-- Returns:
- Result of the DescribeConfigurationRevision operation returned by the service.
- See Also:
-
describeConfigurationRevision
default DescribeConfigurationRevisionResponse describeConfigurationRevision(Consumer<DescribeConfigurationRevisionRequest.Builder> describeConfigurationRevisionRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns the specified configuration revision for the specified configuration.
This is a convenience which creates an instance of the
DescribeConfigurationRevisionRequest.Builderavoiding the need to create one manually viaDescribeConfigurationRevisionRequest.builder()- Parameters:
describeConfigurationRevisionRequest- AConsumerthat will call methods onDescribeConfigurationRevisionRequest.Builderto create a request.- Returns:
- Result of the DescribeConfigurationRevision operation returned by the service.
- See Also:
-
describeUser
default DescribeUserResponse describeUser(DescribeUserRequest describeUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns information about an ActiveMQ user.
- Parameters:
describeUserRequest-- Returns:
- Result of the DescribeUser operation returned by the service.
- See Also:
-
describeUser
default DescribeUserResponse describeUser(Consumer<DescribeUserRequest.Builder> describeUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns information about an ActiveMQ user.
This is a convenience which creates an instance of the
DescribeUserRequest.Builderavoiding the need to create one manually viaDescribeUserRequest.builder()- Parameters:
describeUserRequest- AConsumerthat will call methods onDescribeUserRequest.Builderto create a request.- Returns:
- Result of the DescribeUser operation returned by the service.
- See Also:
-
listBrokers
default ListBrokersResponse listBrokers(ListBrokersRequest listBrokersRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all brokers.
- Parameters:
listBrokersRequest-- Returns:
- Result of the ListBrokers operation returned by the service.
- See Also:
-
listBrokers
default ListBrokersResponse listBrokers(Consumer<ListBrokersRequest.Builder> listBrokersRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all brokers.
This is a convenience which creates an instance of the
ListBrokersRequest.Builderavoiding the need to create one manually viaListBrokersRequest.builder()- Parameters:
listBrokersRequest- AConsumerthat will call methods onListBrokersRequest.Builderto create a request.- Returns:
- Result of the ListBrokers operation returned by the service.
- See Also:
-
listBrokers
default ListBrokersResponse listBrokers() throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqExceptionReturns a list of all brokers.
- Returns:
- Result of the ListBrokers operation returned by the service.
- See Also:
-
listBrokersPaginator
default ListBrokersIterable listBrokersPaginator() throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqExceptionThis is a variant of
listBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
2) Using For loopsoftware.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); responses.stream().forEach(....);{ @code software.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); for (software.amazon.awssdk.services.mq.model.ListBrokersResponse response : responses) { // do something; } }3) Use iterator directlysoftware.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); responses.iterator().forEachRemaining(....);Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listBrokersPaginator
default ListBrokersIterable listBrokersPaginator(ListBrokersRequest listBrokersRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException This is a variant of
listBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
2) Using For loopsoftware.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); responses.stream().forEach(....);{ @code software.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); for (software.amazon.awssdk.services.mq.model.ListBrokersResponse response : responses) { // do something; } }3) Use iterator directlysoftware.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); responses.iterator().forEachRemaining(....);Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation.- Parameters:
listBrokersRequest-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listBrokersPaginator
default ListBrokersIterable listBrokersPaginator(Consumer<ListBrokersRequest.Builder> listBrokersRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException This is a variant of
listBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
2) Using For loopsoftware.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); responses.stream().forEach(....);{ @code software.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); for (software.amazon.awssdk.services.mq.model.ListBrokersResponse response : responses) { // do something; } }3) Use iterator directlysoftware.amazon.awssdk.services.mq.paginators.ListBrokersIterable responses = client.listBrokersPaginator(request); responses.iterator().forEachRemaining(....);Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)operation.
This is a convenience which creates an instance of the
ListBrokersRequest.Builderavoiding the need to create one manually viaListBrokersRequest.builder()- Parameters:
listBrokersRequest- AConsumerthat will call methods onListBrokersRequest.Builderto create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listConfigurationRevisions
default ListConfigurationRevisionsResponse listConfigurationRevisions(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all revisions for the specified configuration.
- Parameters:
listConfigurationRevisionsRequest-- Returns:
- Result of the ListConfigurationRevisions operation returned by the service.
- See Also:
-
listConfigurationRevisions
default ListConfigurationRevisionsResponse listConfigurationRevisions(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all revisions for the specified configuration.
This is a convenience which creates an instance of the
ListConfigurationRevisionsRequest.Builderavoiding the need to create one manually viaListConfigurationRevisionsRequest.builder()- Parameters:
listConfigurationRevisionsRequest- AConsumerthat will call methods onListConfigurationRevisionsRequest.Builderto create a request.- Returns:
- Result of the ListConfigurationRevisions operation returned by the service.
- See Also:
-
listConfigurations
default ListConfigurationsResponse listConfigurations(ListConfigurationsRequest listConfigurationsRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all configurations.
- Parameters:
listConfigurationsRequest-- Returns:
- Result of the ListConfigurations operation returned by the service.
- See Also:
-
listConfigurations
default ListConfigurationsResponse listConfigurations(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest) throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all configurations.
This is a convenience which creates an instance of the
ListConfigurationsRequest.Builderavoiding the need to create one manually viaListConfigurationsRequest.builder()- Parameters:
listConfigurationsRequest- AConsumerthat will call methods onListConfigurationsRequest.Builderto create a request.- Returns:
- Result of the ListConfigurations operation returned by the service.
- See Also:
-
listConfigurations
default ListConfigurationsResponse listConfigurations() throws BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqExceptionReturns a list of all configurations.
- Returns:
- Result of the ListConfigurations operation returned by the service.
- See Also:
-
listTags
default ListTagsResponse listTags(ListTagsRequest listTagsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Lists tags for a resource.
- Parameters:
listTagsRequest-- Returns:
- Result of the ListTags operation returned by the service.
- See Also:
-
listTags
default ListTagsResponse listTags(Consumer<ListTagsRequest.Builder> listTagsRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Lists tags for a resource.
This is a convenience which creates an instance of the
ListTagsRequest.Builderavoiding the need to create one manually viaListTagsRequest.builder()- Parameters:
listTagsRequest- AConsumerthat will call methods onListTagsRequest.Builderto create a request.- Returns:
- Result of the ListTags operation returned by the service.
- See Also:
-
listUsers
default ListUsersResponse listUsers(ListUsersRequest listUsersRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all ActiveMQ users.
- Parameters:
listUsersRequest-- Returns:
- Result of the ListUsers operation returned by the service.
- See Also:
-
listUsers
default ListUsersResponse listUsers(Consumer<ListUsersRequest.Builder> listUsersRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Returns a list of all ActiveMQ users.
This is a convenience which creates an instance of the
ListUsersRequest.Builderavoiding the need to create one manually viaListUsersRequest.builder()- Parameters:
listUsersRequest- AConsumerthat will call methods onListUsersRequest.Builderto create a request.- Returns:
- Result of the ListUsers operation returned by the service.
- See Also:
-
promote
default PromoteResponse promote(PromoteRequest promoteRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Promotes a data replication replica broker to the primary broker role.
- Parameters:
promoteRequest- Promotes a data replication replica broker to the primary broker role.- Returns:
- Result of the Promote operation returned by the service.
- See Also:
-
promote
default PromoteResponse promote(Consumer<PromoteRequest.Builder> promoteRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Promotes a data replication replica broker to the primary broker role.
This is a convenience which creates an instance of the
PromoteRequest.Builderavoiding the need to create one manually viaPromoteRequest.builder()- Parameters:
promoteRequest- AConsumerthat will call methods onPromoteRequest.Builderto create a request. Promotes a data replication replica broker to the primary broker role.- Returns:
- Result of the Promote operation returned by the service.
- See Also:
-
rebootBroker
default RebootBrokerResponse rebootBroker(RebootBrokerRequest rebootBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Reboots a broker. Note: This API is asynchronous.
- Parameters:
rebootBrokerRequest-- Returns:
- Result of the RebootBroker operation returned by the service.
- See Also:
-
rebootBroker
default RebootBrokerResponse rebootBroker(Consumer<RebootBrokerRequest.Builder> rebootBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, MqException Reboots a broker. Note: This API is asynchronous.
This is a convenience which creates an instance of the
RebootBrokerRequest.Builderavoiding the need to create one manually viaRebootBrokerRequest.builder()- Parameters:
rebootBrokerRequest- AConsumerthat will call methods onRebootBrokerRequest.Builderto create a request.- Returns:
- Result of the RebootBroker operation returned by the service.
- See Also:
-
updateBroker
default UpdateBrokerResponse updateBroker(UpdateBrokerRequest updateBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Adds a pending configuration change to a broker.
- Parameters:
updateBrokerRequest- Updates the broker using the specified properties.- Returns:
- Result of the UpdateBroker operation returned by the service.
- See Also:
-
updateBroker
default UpdateBrokerResponse updateBroker(Consumer<UpdateBrokerRequest.Builder> updateBrokerRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Adds a pending configuration change to a broker.
This is a convenience which creates an instance of the
UpdateBrokerRequest.Builderavoiding the need to create one manually viaUpdateBrokerRequest.builder()- Parameters:
updateBrokerRequest- AConsumerthat will call methods onUpdateBrokerRequest.Builderto create a request. Updates the broker using the specified properties.- Returns:
- Result of the UpdateBroker operation returned by the service.
- See Also:
-
updateConfiguration
default UpdateConfigurationResponse updateConfiguration(UpdateConfigurationRequest updateConfigurationRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Updates the specified configuration.
- Parameters:
updateConfigurationRequest- Updates the specified configuration.- Returns:
- Result of the UpdateConfiguration operation returned by the service.
- See Also:
-
updateConfiguration
default UpdateConfigurationResponse updateConfiguration(Consumer<UpdateConfigurationRequest.Builder> updateConfigurationRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Updates the specified configuration.
This is a convenience which creates an instance of the
UpdateConfigurationRequest.Builderavoiding the need to create one manually viaUpdateConfigurationRequest.builder()- Parameters:
updateConfigurationRequest- AConsumerthat will call methods onUpdateConfigurationRequest.Builderto create a request. Updates the specified configuration.- Returns:
- Result of the UpdateConfiguration operation returned by the service.
- See Also:
-
updateUser
default UpdateUserResponse updateUser(UpdateUserRequest updateUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Updates the information for an ActiveMQ user.
- Parameters:
updateUserRequest- Updates the information for an ActiveMQ user.- Returns:
- Result of the UpdateUser operation returned by the service.
- See Also:
-
updateUser
default UpdateUserResponse updateUser(Consumer<UpdateUserRequest.Builder> updateUserRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, MqException Updates the information for an ActiveMQ user.
This is a convenience which creates an instance of the
UpdateUserRequest.Builderavoiding the need to create one manually viaUpdateUserRequest.builder()- Parameters:
updateUserRequest- AConsumerthat will call methods onUpdateUserRequest.Builderto create a request. Updates the information for an ActiveMQ user.- Returns:
- Result of the UpdateUser operation returned by the service.
- See Also:
-
create
Create aMqClientwith the region loaded from theDefaultAwsRegionProviderChainand credentials loaded from theDefaultCredentialsProvider. -
builder
Create a builder that can be used to configure and create aMqClient. -
serviceMetadata
-
serviceClientConfiguration
Description copied from interface:SdkClientThe SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfiguration- Specified by:
serviceClientConfigurationin interfaceAwsClient- Specified by:
serviceClientConfigurationin interfaceSdkClient- Returns:
- SdkServiceClientConfiguration
-