All Products
Search
Document Center

ApsaraMQ for RocketMQ:List of operations by function

Last Updated:Jul 31, 2025
This product(Ons/2019-02-14) OpenAPI adopts RPC Signature style. See signature details in Description of the signature mechanism. We have packaged SDKs for common programming languages for developers. Developers can directly call the OpenAPI of this product by downloading the SDK without paying attention to the technical details. If the existing SDK cannot meet the usage requirements, you can connect through the signature mechanism. It will take about 5 working days. Therefore, it is recommended to join our DingTalk service group (78410016550) and sign under the guidance of experts.
Before using the API, you need to prepare your identity account and access key (AccessKey) to effectively access the API through client tools (SDK, CLI, etc.). For details see getAccessKey.

Service

APITitleDescription
OpenOnsServiceOpenOnsServiceActivates Message Queue for Apache RocketMQ.

Message

APITitleDescription
OnsMessageTraceOnsMessageTraceQueries the consumption status of a message by using the message ID.
OnsMessageGetByMsgIdOnsMessageGetByMsgIdQueries the information about a message by specifying the message ID and determines whether the message has been consumed.
OnsMessageGetByKeyOnsMessageGetByKeyQueries messages by using a specified topic and message key.
OnsMessagePageQueryByTopicOnsMessagePageQueryByTopicQueries all messages that are stored in a specified topic within a specified time range by page.
OnsMessageDetailOnsMessageDetailQueries the details of a message.

Region

APITitleDescription
OnsRegionListOnsRegionListQueries regions where Message Queue for Apache RocketMQ is available.

Instance

APITitleDescription
OnsInstanceCreateOnsInstanceCreateCreates a Message Queue for Apache RocketMQ instance.
OnsInstanceBaseInfoOnsInstanceBaseInfoQueries the basic information of a Message Queue for Apache RocketMQ instance and the endpoint that a client uses to connect to the Message Queue for Apache RocketMQ instance to send and receive messages.
OnsInstanceUpdateOnsInstanceUpdateUpdates the name and description of a Message Queue for Apache RocketMQ instance.
OnsInstanceInServiceListOnsInstanceInServiceListQueries all Message Queue for Apache RocketMQ instances in a specified region within the current account.
OnsInstanceDeleteOnsInstanceDeleteDeletes a Message Queue for Apache RocketMQ instance.

Topic

APITitleDescription
OnsTopicCreateOnsTopicCreateCreates a topic.
OnsTopicStatusOnsTopicStatusQueries the total number of messages in a topic and the status of the topic.
OnsTopicListOnsTopicListQueries the information about topics that belong to the current account.
OnsTopicSubDetailOnsTopicSubDetailQueries the online consumer groups that subscribe to a specified topic.
OnsTopicDeleteOnsTopicDeleteDeletes a topic.

Group

APITitleDescription
OnsGroupCreateOnsGroupCreateCreates a consumer group.
OnsGroupConsumerUpdateOnsGroupConsumerUpdateConfigures read permissions on messages for a consumer group that is identified by a group ID.
OnsGroupListOnsGroupListQueries one or more group IDs.
OnsGroupSubDetailOnsGroupSubDetailQueries all topics to which a specified consumer group subscribes. If no consumer instance in the consumer group is online, no data is returned.
OnsGroupDeleteOnsGroupDeleteDeletes a consumer group.

Tag

APITitleDescription
ListTagResourcesListTagResourcesQueries the tags that are attached to a specified resource.
TagResourcesTagResourcesAdds tags to a resource.
UntagResourcesUntagResourcesDetaches tags from a specified resource and deletes the tags.

Consumer

APITitleDescription
OnsConsumerStatusOnsConsumerStatusQueries the detailed information about the status of a specified consumer group. This operation returns the transactions per second (TPS) for message consumption, load balancing status, consumer connection status, and whether all consumers in the consumer group subscribe to the same topics and tags.
OnsConsumerAccumulateOnsConsumerAccumulateQueries the information about message accumulation in topics to which a specified consumer group subscribes. The returned information includes the number of accumulated messages and the consumption latency.
OnsConsumerGetConnectionOnsConsumerGetConnectionQueries the client connection status of a specified consumer group.
OnsConsumerResetOffsetOnsConsumerResetOffsetResets a consumer offset to a specified timestamp for a consumer group.
OnsConsumerTimeSpanOnsConsumerTimeSpanQueries the time range within which you can specify a point in time to reset the consumer offset for a specified topic. The time range is from the point in time when the earliest stored message was published to the topic to the point in time when the most recently stored message was published to the topic.
OnsMessagePushOnsMessagePushPushes a message to a specified consumer.

Messages tatistics

APITitleDescription
OnsTrendTopicInputTpsOnsTrendTopicInputTpsQueries the statistics about messages that are published to a topic within a period of time.
OnsTrendGroupOutputTpsOnsTrendGroupOutputTpsQueries the statistics about messages that are consumed by a consumer group within a specific period of time.

Trace

APITitleDescription
OnsTraceQueryByMsgIdOnsTraceQueryByMsgIdCreates a task to query the trace of a message based on the message ID and the name of the topic in which the message is stored. The task ID is returned.
OnsTraceQueryByMsgKeyOnsTraceQueryByMsgKeyCreates a trace query task based on the topic name and message key and obtains the ID of the query task.
OnsTraceGetResultOnsTraceGetResultThe tracing results are queried by specifying the ID of a trace query task.

Dead-letter queues

APITitleDescription
OnsDLQMessagePageQueryByGroupIdOnsDLQMessagePageQueryByGroupIdQueries all dead-letter messages in a group within a period of time by page.
OnsDLQMessageGetByIdOnsDLQMessageGetByIdQueries a dead-letter message based on the message ID. The queried information about the dead-letter message includes the point in time when the message is stored, the message body, and attributes such as the message tag and the message key.
OnsDLQMessageResendByIdOnsDLQMessageResendByIdResends a dead-letter message based on a specified message ID so that the dead-letter message can be consumed by consumers.