com.baidubce.services.rocketmq

Class RocketMQClient

java.lang.Object

com.baidubce.AbstractBceClient

com.baidubce.services.rocketmq.RocketMQClient

public class RocketMQClient
extends AbstractBceClient

Field Summary

Fields inherited from class com.baidubce.AbstractBceClient

config, DEFAULT_CONTENT_TYPE, DEFAULT_ENCODING, DEFAULT_SERVICE_DOMAIN, URL_PREFIX

Constructor Summary

Constructors

Constructor and Description
RocketMQClient() Constructs a new client to invoke service methods on bcc.
RocketMQClient(BceClientConfiguration configuration) Constructs a new bcc client using the client configuration to access bcc.
RocketMQClient(BceClientConfiguration configuration, HttpResponseHandler[] responseHandlers, boolean isHttpAsyncPutEnabled) Creates a new client to invoke service methods on bcc.

Method Summary

Modifier and Type	Method and Description
CreateAclUserResponse	createAclUser(CreateAclUserConfigRequest request)
CreateClusterResponse	createCluster(CreateClusterRequest request)
CreateConsumerGroupResponse	createConsumerGroup(CreateConsumerGroupRequest request)
CreateTopicResponse	createTopic(CreateTopicRequest request)
DeleteAclUserConfigResponse	deleteAclUser(DeleteAclUserConfigRequest request)
DeleteClusterResponse	deleteCluster(DeleteClusterRequest request)
DeleteConsumerGroupResponse	deleteConsumerGroup(DeleteConsumerGroupRequest request)
DeleteTopicResponse	deleteTopic(DeleteTopicRequest request)
ExpandBrokerResponse	expandBroker(ExpandBrokerRequest request)
GetClusterAccessEndpointsResponse	getAccessEndpoints(GetClusterAccessEndpointsRequest request)
GetAclUserConfigResponse	getAclUser(GetAclUserRequest request)
GetClusterResponse	getCluster(GetClusterRequest request)
GetConsumerGroupResponse	getConsumerGroup(GetConsumerGroupRequest request)
GetTopicResponse	getTopic(GetTopicRequest request)
IncreaseStorageSizeResponse	increaseStorageSize(IncreaseStorageSizeRequest request)
ListActionOperationsResponse	listActionOperations(ListActionOperationsRequest request)
ListClusterAclUserConfigsResponse	listClusterAclUsers(ListClusterAclUserConfigsRequest request)
ListClusterActionsResponse	listClusterAclUsers(ListClusterActionsRequest request)
ListClusterBrokerNodesResponse	listClusterBrokerNodes(ListClusterBrokerNodesRequest request)
ListClusterConsumerGroupsResponse	listClusterConsumerGroups(ListClusterConsumerGroupsRequest request)
ListClustersResponse	listClusters(ListClustersRequest request) Lists clusters.
ListClusterTopicsResponse	listClusterTopics(ListClusterTopicsRequest request)
ListConsumerClientsResponse	listConsumerClients(ListConsumerClientsRequest request)
ListConsumerGroupSubscriptionsResponse	listConsumerGroupSubscriptions(ListConsumerGroupSubscriptionsRequest request)
ListConsumerGroupUsersResponse	listConsumerGroupUsers(ListConsumerGroupUsersRequest request)
ListConsumeStatesResponse	listConsumeStates(ListConsumeStatesRequest request)
ListTopicQueuesResponse	listTopicQueue(ListTopicQueuesRequest request)
ListTopicSubscriptionsResponse	listTopicSubscription(ListTopicSubscriptionsRequest request)
ListTopicUsersResponse	listTopicUsers(ListTopicUsersRequest request)
ModifyBrokerNodeTypeResponse	modifyBrokerNodeType(ModifyBrokerNodeTypeRequest request)
QueryMessageResponse	queryMessage(QueryMessageRequest request)
QueryMessageListResponse	queryMessageList(QueryMessageListRequest request)
ResetConsumeOffsetResponse	resetConsumeOffset(ResetConsumeOffsetRequest request)
RestartBrokerNodeResponse	restartBrokerNode(RestartBrokerNodeRequest request)
SendMessageResponse	sendMessage(SendMessageRequest request)
StartClusterResponse	startCluster(StartClusterRequest request)
StopClusterResponse	stopCluster(StopClusterRequest request)
UpdateAclUserConfigResponse	updateAclUser(UpdateAclUserConfigRequest request)
UpdateConsumerGroupResponse	updateConsumerGroup(UpdateConsumerGroupRequest request)
UpdateTopicResponse	updateTopic(UpdateTopicRequest request)

Methods inherited from class com.baidubce.AbstractBceClient

abortCurrentRequest, computeBktVirEndpoint, computeServiceId, getBktVirEndpoint, getClient, getEndpoint, getServiceId, invokeHttpClient, isRegionSupported, setClient, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocketMQClient

public RocketMQClient()

Constructs a new client to invoke service methods on bcc.

RocketMQClient

public RocketMQClient(BceClientConfiguration configuration)

Constructs a new bcc client using the client configuration to access bcc.

Parameters:

configuration - The bcc client configuration options controlling how this client connects to bcc (e.g. proxy settings, retry counts, etc.).

RocketMQClient

public RocketMQClient(BceClientConfiguration configuration,
                      HttpResponseHandler[] responseHandlers,
                      boolean isHttpAsyncPutEnabled)

Creates a new client to invoke service methods on bcc.

Parameters:

configuration - The bcc client configuration options controlling how this client

responseHandlers - The response handlers to be used when executing requests.

isHttpAsyncPutEnabled - Whether PUT method use Async manner.

Method Detail

listClusters

public ListClustersResponse listClusters(ListClustersRequest request)

Lists clusters.

Parameters:

request - The request object to be executed.

Returns:

The response object containing the result of the request.

createCluster

public CreateClusterResponse createCluster(CreateClusterRequest request)

getCluster

public GetClusterResponse getCluster(GetClusterRequest request)

deleteCluster

public DeleteClusterResponse deleteCluster(DeleteClusterRequest request)

stopCluster

public StopClusterResponse stopCluster(StopClusterRequest request)

startCluster

public StartClusterResponse startCluster(StartClusterRequest request)

getAccessEndpoints

public GetClusterAccessEndpointsResponse getAccessEndpoints(GetClusterAccessEndpointsRequest request)

listClusterBrokerNodes

public ListClusterBrokerNodesResponse listClusterBrokerNodes(ListClusterBrokerNodesRequest request)

listClusterTopics

public ListClusterTopicsResponse listClusterTopics(ListClusterTopicsRequest request)

listClusterConsumerGroups

public ListClusterConsumerGroupsResponse listClusterConsumerGroups(ListClusterConsumerGroupsRequest request)

listClusterAclUsers

public ListClusterAclUserConfigsResponse listClusterAclUsers(ListClusterAclUserConfigsRequest request)

listClusterAclUsers

public ListClusterActionsResponse listClusterAclUsers(ListClusterActionsRequest request)

increaseStorageSize

public IncreaseStorageSizeResponse increaseStorageSize(IncreaseStorageSizeRequest request)

expandBroker

public ExpandBrokerResponse expandBroker(ExpandBrokerRequest request)

modifyBrokerNodeType

public ModifyBrokerNodeTypeResponse modifyBrokerNodeType(ModifyBrokerNodeTypeRequest request)

restartBrokerNode

public RestartBrokerNodeResponse restartBrokerNode(RestartBrokerNodeRequest request)

createTopic

public CreateTopicResponse createTopic(CreateTopicRequest request)

getTopic

public GetTopicResponse getTopic(GetTopicRequest request)

updateTopic

public UpdateTopicResponse updateTopic(UpdateTopicRequest request)

deleteTopic

public DeleteTopicResponse deleteTopic(DeleteTopicRequest request)

listTopicQueue

public ListTopicQueuesResponse listTopicQueue(ListTopicQueuesRequest request)

listTopicSubscription

public ListTopicSubscriptionsResponse listTopicSubscription(ListTopicSubscriptionsRequest request)

queryMessageList

public QueryMessageListResponse queryMessageList(QueryMessageListRequest request)

listTopicUsers

public ListTopicUsersResponse listTopicUsers(ListTopicUsersRequest request)

createConsumerGroup

public CreateConsumerGroupResponse createConsumerGroup(CreateConsumerGroupRequest request)

getConsumerGroup

public GetConsumerGroupResponse getConsumerGroup(GetConsumerGroupRequest request)

updateConsumerGroup

public UpdateConsumerGroupResponse updateConsumerGroup(UpdateConsumerGroupRequest request)

deleteConsumerGroup

public DeleteConsumerGroupResponse deleteConsumerGroup(DeleteConsumerGroupRequest request)

resetConsumeOffset

public ResetConsumeOffsetResponse resetConsumeOffset(ResetConsumeOffsetRequest request)

listConsumerClients

public ListConsumerClientsResponse listConsumerClients(ListConsumerClientsRequest request)

listConsumerGroupSubscriptions

public ListConsumerGroupSubscriptionsResponse listConsumerGroupSubscriptions(ListConsumerGroupSubscriptionsRequest request)

listConsumerGroupUsers

public ListConsumerGroupUsersResponse listConsumerGroupUsers(ListConsumerGroupUsersRequest request)

listConsumeStates

public ListConsumeStatesResponse listConsumeStates(ListConsumeStatesRequest request)

createAclUser

public CreateAclUserResponse createAclUser(CreateAclUserConfigRequest request)

getAclUser

public GetAclUserConfigResponse getAclUser(GetAclUserRequest request)

updateAclUser

public UpdateAclUserConfigResponse updateAclUser(UpdateAclUserConfigRequest request)

deleteAclUser

public DeleteAclUserConfigResponse deleteAclUser(DeleteAclUserConfigRequest request)

sendMessage

public SendMessageResponse sendMessage(SendMessageRequest request)

queryMessage

public QueryMessageResponse queryMessage(QueryMessageRequest request)

listActionOperations

public ListActionOperationsResponse listActionOperations(ListActionOperationsRequest request)