rocketmq

Documentation

Index

• type RocketMQ
  • func New(rm *pipeline.RocketMQ) (r *RocketMQ, err error)
  • func (r *RocketMQ) Close() error
  • func (r *RocketMQ) Send(msg *message2.Message) (ok bool, err error)

Types

type RocketMQ

type RocketMQ struct {
	RocketMQ *pipeline.RocketMQ
	// contains filtered or unexported fields
}

RocketMQ send message to Aliyun's RocketMQ

func New

func New(rm *pipeline.RocketMQ) (r *RocketMQ, err error)

New returns a new RocketMQ

func (*RocketMQ) Close

func (r *RocketMQ) Close() error

func (*RocketMQ) Send

func (r *RocketMQ) Send(msg *message2.Message) (ok bool, err error)

Send logic and control