You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
25 lines
655 B
25 lines
655 B
package rocketmq
|
|
|
|
import (
|
|
"github.com/apache/rocketmq-client-go/v2"
|
|
"github.com/apache/rocketmq-client-go/v2/primitive"
|
|
"github.com/apache/rocketmq-client-go/v2/producer"
|
|
"log"
|
|
)
|
|
|
|
var MqPool *rocketmq.Producer
|
|
|
|
func MqConnect() {
|
|
MqPool, err := rocketmq.NewProducer(
|
|
producer.WithGroupName("ProductService"),
|
|
producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"127.0.0.1:9876"})),
|
|
//producer.WithCreateTopicKey("product"),
|
|
producer.WithRetry(1))
|
|
if err != nil {
|
|
log.Println("New ProductService producer failed", err)
|
|
}
|
|
err = MqPool.Start()
|
|
if err != nil {
|
|
log.Println("ProductService producer start failed", err)
|
|
}
|
|
}
|