jcq消费消息

platformapi/jcqapi/jcqapi.go

@@ -18,7 +18,7 @@ import (
 const (
 	sigKey = "signature"
 
-	httpURL = "jcq-hb-yd-001-httpsrv-nlb-FI.jvessel-open-hb.jdcloud.com:8080"
+	httpURL = "http://jcq-hb-yd-001-httpsrv-nlb-FI.jvessel-open-hb.jdcloud.com:8080"
 
 	TopicCreateOrder           = "open_message_pop_order_create_E1D746D42474D5F1F1A10CECE75D99F6"
 	ConsumerGroupIdCreateOrder = "open_message_573819178445"
@@ -105,6 +105,7 @@ func (a *API) ConsumeInfo(topic, consumerGroupId string) (consumeInfoResult *Con
 	result, err := a.AccessAPI("v1/messages", httpURL, map[string]interface{}{
 		"topic":           topic,
 		"consumerGroupId": consumerGroupId,
+		"size":            1,
 	})
 	if err == nil {
 		utils.Map2StructByJson(result, &consumeInfoResult, false)

platformapi/jcqapi/jcqapi_test.go

@@ -1,2 +1,30 @@
 package jcqapi
 
+import (
+	"testing"
+
+	"git.rosy.net.cn/baseapi"
+	"go.uber.org/zap"
+
+	"git.rosy.net.cn/baseapi/utils"
+)
+
+var (
+	api         *API
+	sugarLogger *zap.SugaredLogger
+)
+
+func init() {
+	logger, _ := zap.NewDevelopment()
+	sugarLogger = logger.Sugar()
+	baseapi.Init(sugarLogger)
+	api = New("C0EB36912C652079DB111A922ACA406B", "86B6330051ECC88391E2630D34C2CA13")
+}
+
+func TestConsumeInfo(t *testing.T) {
+	result, err := api.ConsumeInfo("topic-a08u00zul9", "open_message_573819178445")
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(utils.Format4Output(result, false))
+}