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 |
Did this article solve your problem?
Thank you for your score!Your feedback would help us improve the website.