Commit 94c9c16d by feidy

add ali rocketmq test

parent 9d3b252e
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
* @Author: zhoufei * @Author: zhoufei
* @Date: 2022-04-22 14:58:25 * @Date: 2022-04-22 14:58:25
* @LastEditors: zhoufei * @LastEditors: zhoufei
* @LastEditTime: 2022-04-24 17:46:43 * @LastEditTime: 2022-04-24 18:48:25
* @FilePath: /utils/queue/rocketmq.go * @FilePath: /utils/queue/rocketmq.go
* @Description:rocketmq 工具类 * @Description:rocketmq 工具类
* *
...@@ -91,7 +91,7 @@ func (r *RocketMq) RegisterConsumer(topic string, recevieFunc func(qMsg *QueueMs ...@@ -91,7 +91,7 @@ func (r *RocketMq) RegisterConsumer(topic string, recevieFunc func(qMsg *QueueMs
return errors.New("no consumer available") return errors.New("no consumer available")
} }
err = r.consumer.Subscribe(topic, consumer.MessageSelector{}, func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { err = r.consumer.Subscribe(topic, consumer.MessageSelector{}, func(_ context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) {
for _, msg := range msgs { for _, msg := range msgs {
go recevieFunc(&QueueMsg{ go recevieFunc(&QueueMsg{
Body: msg.Body, Body: msg.Body,
......
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
* @Author: zhoufei * @Author: zhoufei
* @Date: 2022-04-24 14:19:58 * @Date: 2022-04-24 14:19:58
* @LastEditors: zhoufei * @LastEditors: zhoufei
* @LastEditTime: 2022-04-24 17:53:46 * @LastEditTime: 2022-04-25 09:24:52
* @FilePath: /utils/queue/rocketmq_test.go * @FilePath: /utils/queue/rocketmq_test.go
* @Description: rocketmq 测试 * @Description: rocketmq 测试
* *
...@@ -78,3 +78,22 @@ func TestRocketMqConsumer(t *testing.T) { ...@@ -78,3 +78,22 @@ func TestRocketMqConsumer(t *testing.T) {
procucer.ShutDown() procucer.ShutDown()
client.ShutDown() client.ShutDown()
} }
func TestAliRocket(t *testing.T) {
p, err := NewRocketMqProducer([]string{"http://onsaddr.mq-internet-access.mq-internet.aliyuncs.com:80"}, "test", 2,
WithRocketAcl("xxxxx", "xxxxxxxx"))
if err != nil {
t.Fatal(err)
}
data := `{"a":"b"}`
msg, err := p.SendStringMsg("xxxx", data)
if err != nil {
t.Fatal(err)
}
fmt.Println(msg.Info["msgId"])
p.ShutDown()
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment