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.