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 String
Value for looking up the service's metadata from theServiceMetadataProvider
.static final String
-
Method Summary
Modifier and TypeMethodDescriptionstatic MqClientBuilder
builder()
Create a builder that can be used to configure and create aMqClient
.static MqClient
create()
Create aMqClient
with the region loaded from theDefaultAwsRegionProviderChain
and credentials loaded from theDefaultCredentialsProvider
.default CreateBrokerResponse
createBroker
(Consumer<CreateBrokerRequest.Builder> createBrokerRequest) Creates a broker.default CreateBrokerResponse
createBroker
(CreateBrokerRequest createBrokerRequest) Creates a broker.default CreateConfigurationResponse
createConfiguration
(Consumer<CreateConfigurationRequest.Builder> createConfigurationRequest) Creates a new configuration for the specified configuration name.default CreateConfigurationResponse
createConfiguration
(CreateConfigurationRequest createConfigurationRequest) Creates a new configuration for the specified configuration name.default CreateTagsResponse
createTags
(Consumer<CreateTagsRequest.Builder> createTagsRequest) Add a tag to a resource.default CreateTagsResponse
createTags
(CreateTagsRequest createTagsRequest) Add a tag to a resource.default CreateUserResponse
createUser
(Consumer<CreateUserRequest.Builder> createUserRequest) Creates an ActiveMQ user.default CreateUserResponse
createUser
(CreateUserRequest createUserRequest) Creates an ActiveMQ user.default DeleteBrokerResponse
deleteBroker
(Consumer<DeleteBrokerRequest.Builder> deleteBrokerRequest) Deletes a broker.default DeleteBrokerResponse
deleteBroker
(DeleteBrokerRequest deleteBrokerRequest) Deletes a broker.default DeleteTagsResponse
deleteTags
(Consumer<DeleteTagsRequest.Builder> deleteTagsRequest) Removes a tag from a resource.default DeleteTagsResponse
deleteTags
(DeleteTagsRequest deleteTagsRequest) Removes a tag from a resource.default DeleteUserResponse
deleteUser
(Consumer<DeleteUserRequest.Builder> deleteUserRequest) Deletes an ActiveMQ user.default DeleteUserResponse
deleteUser
(DeleteUserRequest deleteUserRequest) Deletes an ActiveMQ user.default DescribeBrokerResponse
describeBroker
(Consumer<DescribeBrokerRequest.Builder> describeBrokerRequest) Returns information about the specified broker.default DescribeBrokerResponse
describeBroker
(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 DescribeConfigurationResponse
describeConfiguration
(Consumer<DescribeConfigurationRequest.Builder> describeConfigurationRequest) Returns information about the specified configuration.default DescribeConfigurationResponse
describeConfiguration
(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 DescribeUserResponse
describeUser
(Consumer<DescribeUserRequest.Builder> describeUserRequest) Returns information about an ActiveMQ user.default DescribeUserResponse
describeUser
(DescribeUserRequest describeUserRequest) Returns information about an ActiveMQ user.default ListBrokersResponse
Returns a list of all brokers.default ListBrokersResponse
listBrokers
(Consumer<ListBrokersRequest.Builder> listBrokersRequest) Returns a list of all brokers.default ListBrokersResponse
listBrokers
(ListBrokersRequest listBrokersRequest) Returns a list of all brokers.default ListBrokersIterable
This is a variant oflistBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)
operation.default ListBrokersIterable
listBrokersPaginator
(Consumer<ListBrokersRequest.Builder> listBrokersRequest) This is a variant oflistBrokers(software.amazon.awssdk.services.mq.model.ListBrokersRequest)
operation.default ListBrokersIterable
listBrokersPaginator
(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 ListConfigurationsResponse
Returns a list of all configurations.default ListConfigurationsResponse
listConfigurations
(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest) Returns a list of all configurations.default ListConfigurationsResponse
listConfigurations
(ListConfigurationsRequest listConfigurationsRequest) Returns a list of all configurations.default ListTagsResponse
listTags
(Consumer<ListTagsRequest.Builder> listTagsRequest) Lists tags for a resource.default ListTagsResponse
listTags
(ListTagsRequest listTagsRequest) Lists tags for a resource.default ListUsersResponse
listUsers
(Consumer<ListUsersRequest.Builder> listUsersRequest) Returns a list of all ActiveMQ users.default ListUsersResponse
listUsers
(ListUsersRequest listUsersRequest) Returns a list of all ActiveMQ users.default PromoteResponse
promote
(Consumer<PromoteRequest.Builder> promoteRequest) Promotes a data replication replica broker to the primary broker role.default PromoteResponse
promote
(PromoteRequest promoteRequest) Promotes a data replication replica broker to the primary broker role.default RebootBrokerResponse
rebootBroker
(Consumer<RebootBrokerRequest.Builder> rebootBrokerRequest) Reboots a broker.default RebootBrokerResponse
rebootBroker
(RebootBrokerRequest rebootBrokerRequest) Reboots a broker.default MqServiceClientConfiguration
The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfigurationstatic ServiceMetadata
default UpdateBrokerResponse
updateBroker
(Consumer<UpdateBrokerRequest.Builder> updateBrokerRequest) Adds a pending configuration change to a broker.default UpdateBrokerResponse
updateBroker
(UpdateBrokerRequest updateBrokerRequest) Adds a pending configuration change to a broker.default UpdateConfigurationResponse
updateConfiguration
(Consumer<UpdateConfigurationRequest.Builder> updateConfigurationRequest) Updates the specified configuration.default UpdateConfigurationResponse
updateConfiguration
(UpdateConfigurationRequest updateConfigurationRequest) Updates the specified configuration.default UpdateUserResponse
updateUser
(Consumer<UpdateUserRequest.Builder> updateUserRequest) Updates the information for an ActiveMQ user.default UpdateUserResponse
updateUser
(UpdateUserRequest updateUserRequest) Updates the information for an ActiveMQ user.Methods inherited from interface software.amazon.awssdk.utils.SdkAutoCloseable
close
Methods 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.Builder
avoiding the need to create one manually viaCreateBrokerRequest.builder()
- Parameters:
createBrokerRequest
- AConsumer
that will call methods onCreateBrokerRequest.Builder
to 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.Builder
avoiding the need to create one manually viaCreateConfigurationRequest.builder()
- Parameters:
createConfigurationRequest
- AConsumer
that will call methods onCreateConfigurationRequest.Builder
to 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.Builder
avoiding the need to create one manually viaCreateTagsRequest.builder()
- Parameters:
createTagsRequest
- AConsumer
that will call methods onCreateTagsRequest.Builder
to 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.Builder
avoiding the need to create one manually viaCreateUserRequest.builder()
- Parameters:
createUserRequest
- AConsumer
that will call methods onCreateUserRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDeleteBrokerRequest.builder()
- Parameters:
deleteBrokerRequest
- AConsumer
that will call methods onDeleteBrokerRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDeleteTagsRequest.builder()
- Parameters:
deleteTagsRequest
- AConsumer
that will call methods onDeleteTagsRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDeleteUserRequest.builder()
- Parameters:
deleteUserRequest
- AConsumer
that will call methods onDeleteUserRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDescribeBrokerRequest.builder()
- Parameters:
describeBrokerRequest
- AConsumer
that will call methods onDescribeBrokerRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDescribeBrokerEngineTypesRequest.builder()
- Parameters:
describeBrokerEngineTypesRequest
- AConsumer
that will call methods onDescribeBrokerEngineTypesRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDescribeBrokerInstanceOptionsRequest.builder()
- Parameters:
describeBrokerInstanceOptionsRequest
- AConsumer
that will call methods onDescribeBrokerInstanceOptionsRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDescribeConfigurationRequest.builder()
- Parameters:
describeConfigurationRequest
- AConsumer
that will call methods onDescribeConfigurationRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDescribeConfigurationRevisionRequest.builder()
- Parameters:
describeConfigurationRevisionRequest
- AConsumer
that will call methods onDescribeConfigurationRevisionRequest.Builder
to 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.Builder
avoiding the need to create one manually viaDescribeUserRequest.builder()
- Parameters:
describeUserRequest
- AConsumer
that will call methods onDescribeUserRequest.Builder
to 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.Builder
avoiding the need to create one manually viaListBrokersRequest.builder()
- Parameters:
listBrokersRequest
- AConsumer
that will call methods onListBrokersRequest.Builder
to 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 Streamsoftware.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 Streamsoftware.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 Streamsoftware.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.Builder
avoiding the need to create one manually viaListBrokersRequest.builder()
- Parameters:
listBrokersRequest
- AConsumer
that will call methods onListBrokersRequest.Builder
to 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.Builder
avoiding the need to create one manually viaListConfigurationRevisionsRequest.builder()
- Parameters:
listConfigurationRevisionsRequest
- AConsumer
that will call methods onListConfigurationRevisionsRequest.Builder
to 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.Builder
avoiding the need to create one manually viaListConfigurationsRequest.builder()
- Parameters:
listConfigurationsRequest
- AConsumer
that will call methods onListConfigurationsRequest.Builder
to 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.Builder
avoiding the need to create one manually viaListTagsRequest.builder()
- Parameters:
listTagsRequest
- AConsumer
that will call methods onListTagsRequest.Builder
to 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.Builder
avoiding the need to create one manually viaListUsersRequest.builder()
- Parameters:
listUsersRequest
- AConsumer
that will call methods onListUsersRequest.Builder
to 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.Builder
avoiding the need to create one manually viaPromoteRequest.builder()
- Parameters:
promoteRequest
- AConsumer
that will call methods onPromoteRequest.Builder
to 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.Builder
avoiding the need to create one manually viaRebootBrokerRequest.builder()
- Parameters:
rebootBrokerRequest
- AConsumer
that will call methods onRebootBrokerRequest.Builder
to 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.Builder
avoiding the need to create one manually viaUpdateBrokerRequest.builder()
- Parameters:
updateBrokerRequest
- AConsumer
that will call methods onUpdateBrokerRequest.Builder
to 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.Builder
avoiding the need to create one manually viaUpdateConfigurationRequest.builder()
- Parameters:
updateConfigurationRequest
- AConsumer
that will call methods onUpdateConfigurationRequest.Builder
to 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.Builder
avoiding the need to create one manually viaUpdateUserRequest.builder()
- Parameters:
updateUserRequest
- AConsumer
that will call methods onUpdateUserRequest.Builder
to create a request. Updates the information for an ActiveMQ user.- Returns:
- Result of the UpdateUser operation returned by the service.
- See Also:
-
create
Create aMqClient
with the region loaded from theDefaultAwsRegionProviderChain
and credentials loaded from theDefaultCredentialsProvider
. -
builder
Create a builder that can be used to configure and create aMqClient
. -
serviceMetadata
-
serviceClientConfiguration
Description copied from interface:SdkClient
The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfiguration- Specified by:
serviceClientConfiguration
in interfaceAwsClient
- Specified by:
serviceClientConfiguration
in interfaceSdkClient
- Returns:
- SdkServiceClientConfiguration
-