rocketmq

package

v0.2.0 Latest Latest Go to latest Published: Jun 2, 2024 License: BSD-3-Clause Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/9d77v/band

Links

Open Source Insights

Documentation ¶

Index ¶

type RocketMQProducer
- func NewRocketMQProducer(conf prod.Conf) (*RocketMQProducer, error)
- func (p *RocketMQProducer) SendAsync(ctx context.Context, ...) error
- func (p *RocketMQProducer) SendSync(ctx context.Context, msgs ...*mq.Message) (*mq.SendResult, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type RocketMQProducer ¶

type RocketMQProducer struct {
	Conf     prod.Conf
	Producer rocketmq.Producer
}

func NewRocketMQProducer ¶

func NewRocketMQProducer(conf prod.Conf) (*RocketMQProducer, error)

func (*RocketMQProducer) SendAsync ¶

func (p *RocketMQProducer) SendAsync(ctx context.Context, callback func(ctx context.Context, result *mq.SendResult, err error), msgs ...*mq.Message) error

func (*RocketMQProducer) SendSync ¶

func (p *RocketMQProducer) SendSync(ctx context.Context, msgs ...*mq.Message) (*mq.SendResult, error)

Source Files ¶

View all Source files

rocketmq_producer.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL