rabbitmq

Documentation

Index

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

Types

type RabbitMQ

type RabbitMQ struct {
	RabbitMQ   *pipeline.RabbitMQ
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

RabbitMQ send message to RabbitMQ

func New

func New(rq *pipeline.RabbitMQ) (r *RabbitMQ, err error)

New returns a new RabbitMQ object

func (*RabbitMQ) Close

func (r *RabbitMQ) Close() error

func (*RabbitMQ) Send

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

Send Logic and control