producer

Documentation

Index

• func SendAsync(ctx context.Context, ...) error
• func SendOneWay(ctx context.Context, mq ...*primitive.Message) error
• func SendSync(ctx context.Context, mq ...*primitive.Message) (*primitive.SendResult, error)
• type Producer

Functions

func SendAsync

func SendAsync(ctx context.Context, mq func(ctx context.Context, result *primitive.SendResult, err error),
	msg ...*primitive.Message) error

SendAsync 异步消息

func SendOneWay

func SendOneWay(ctx context.Context, mq ...*primitive.Message) error

SendOneWay 发送单方面消息

func SendSync

func SendSync(ctx context.Context, mq ...*primitive.Message) (*primitive.SendResult, error)

SendSync 同步消息

Types

type Producer

type Producer struct {
	rocket.Rocketmq `yaml:",inline" mapstructure:",squash"`
}