DMS

The SDK interfaces based on the DMS v1.0 API are as follows. For details about the invoking methods, see the sample codes.

Interface

Method

API

QueueService

Queue create(String name, String description)

POST /v1.0/{project_id}/queues

List<? extends Queue> list()

GET /v1.0/{project_id}/queues

Queue get(String queueId)

GET /v1.0/{project_id}/queues/{queue_id}

ActionResponse delete(String queueId)

DELETE /v1.0/{project_id}/queues/{queue_id}

ConsumerGroupService

ConsumerGroup create(String queueId, String consumerGroupName)

POST /v1.0/{project_id}/queues/{queue_id}/groups

List<ConsumerGroup> list(String queueId)

GET /v1.0/{project_id}/queues/{queue_id}/groups

ActionResponse delete(String queueId, String consumerGroupId)

DELETE /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}

QueueMessageService

ActionResponse produce(String queueId, QueueMessage message)

POST /v1.0/{project_id}/queues/{queue_id}/messages

List<QueueMessageWithHandler> consume(String queueId, String consumerGroupId, Integer maxMessages, Integer timeWait)

GET /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/messages

ConsumeConfirmResponse confirmConsuming(String queueId, String consumerGroupId,Map<String, ConsumeStatus> consumeResult)

POST /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/ack

MessageQueueQuotaService

List<Quota> get()

GET /v1.0/{project_id}/quotas/dms