Registry /
messaging / apache-rocketmq-client-go-v2
Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
rocketmq
✓ github.com/apache/rocketmq-client-go/v2
Send a synchronous message to RocketMQ.
package main
import (
"context"
"fmt"
"os"
"github.com/apache/rocketmq-client-go/v2"
"github.com/apache/rocketmq-client-go/v2/primitive"
)
func main() {
producer, err := rocketmq.NewProducer(
rocketmq.WithNameServer([]string{"127.0.0.1:9876"}),
)
if err != nil {
fmt.Printf("NewProducer error: %s\n", err)
os.Exit(1)
}
err = producer.Start()
if err != nil {
fmt.Printf("Start producer error: %s\n", err)
os.Exit(1)
}
defer producer.Shutdown()
msg := &primitive.Message{
Topic: "test",
Body: []byte("Hello RocketMQ"),
}
res, err := producer.SendSync(context.Background(), msg)
if err != nil {
fmt.Printf("Send message error: %s\n", err)
os.Exit(1)
}
fmt.Printf("Send result: %s\n", res.String())
}
Upgrade
Version history
2.1.2latest on pkg.go.dev
Audit
Dependencies
No dependency data recorded yet.