cmq-go

Tencent CMQ Golang SDK

与腾讯云官方SDK接口保持一致

Getting Started

所有的API中都有test case，这里使用CreateQueue举例。

var secretId = "YourTencentSecretId"
var secretKey = "YourTencentSecretKey"
var endpointQueue = "https://cmq-queue-sh.api.qcloud.com"
var endpointQueueInner = "http://cmq-queue-sh.api.tencentyun.com"

// 创建队列
func Test_CreateQueue(t *testing.T) {
    //创建账户
	account := cmq_go.NewAccount(endpointQueue, secretId, secretKey)
	
	//设置队列metadata
	meta := cmq_go.QueueMeta{}
	meta.PollingWaitSeconds = 10
	meta.VisibilityTimeout = 10
	meta.MaxMsgSize = 1048576
	meta.MsgRetentionSeconds = 345600

    //创建队列queue-test-001
	err := account.CreateQueue("queue-test-001", meta)
	if err != nil {
		t.Errorf("queue-test-001 created failed, %v", err.Error())
		return
	}
	t.Log("queue-test-001 created")

    //创建队列queue-test-002
	err = account.CreateQueue("queue-test-002", meta)
	if err != nil {
		t.Errorf("queue-test-002 created failed, %v", err.Error())
		return
	}
	t.Log("queue-test-002 created")
}

Test Case

测试单个方法
go test -v -test.run Test_CreateQueue

API Status

队列模型

队列相关接口

• CreateQueue
• ListQueue
• GetQueueAttributes
• SetQueueAttributes
• DeleteQueue

消息相关接口

• SendMessage
• BatchSendMessage
• ReceiveMessage
• BatchReceiveMessage
• DeleteMessage
• BatchDeleteMessage

主题模型

主题相关接口

• CreateTopic
• SetTopicAttributes
• ListTopic
• GetTopicAttributes
• DeleteTopic

消息相关接口

• PublishMessage
• BatchPublishMessage

订阅相关接口

• Subscribe
• ListSubscriptionByTopic
• SetSubscriptionAttributes
• GetSubscriptionAttributes
• Unsubscribe