rmq

Documentation

Index

• type Message
  • func NewMessage(bytes []byte, xattr map[string]string) *Message
  • func (m *Message) ToXAttrs() map[string]string
• type Override
• type RabbitMQ
  • func NewConsumer(amqpURI, exchange, queue, routingKey, tag string, prefetch int) *RabbitMQ
  • func NewPublisher(amqpURI, exchange, queue, tag string, prefetch int) *RabbitMQ
  • func (r *RabbitMQ) Close() error
  • func (r *RabbitMQ) Consume(out chan Message, verify <-chan Verify)
  • func (r *RabbitMQ) Publish(messages chan Message, o Override)
• type Verify

Types

type Message

type Message struct {
	Body        []byte
	RoutingKey  string
	Headers     amqp.Table
	DeliveryTag uint64
}

Message contains the most basic about the message

func NewMessage

func NewMessage(bytes []byte, xattr map[string]string) *Message

NewMessage will create a new message from a byte slice and attributes

func (*Message) ToXAttrs

func (m *Message) ToXAttrs() map[string]string

ToXAttrs takes amqp headers and convert them to attributes

type Override

type Override struct {
	RoutingKey string
}

Override will be used to override RabbitMQ settings on publishing messages

type RabbitMQ

type RabbitMQ struct {
	Wg *sync.WaitGroup
	// contains filtered or unexported fields
}

RabbitMQ type for talking to RabbitMQ

func NewConsumer

func NewConsumer(amqpURI, exchange, queue, routingKey, tag string, prefetch int) *RabbitMQ

NewConsumer creates and sets up a RabbitMQ struct best used for consuming messages

func NewPublisher

func NewPublisher(amqpURI, exchange, queue, tag string, prefetch int) *RabbitMQ

NewPublisher creates and sets up a RabbitMQ Publisher

func (*RabbitMQ) Close

func (r *RabbitMQ) Close() error

Close will close the RabbitMQ channel and connection

func (*RabbitMQ) Consume

func (r *RabbitMQ) Consume(out chan Message, verify <-chan Verify)

Consume outputs a stream of Message into a channel from rabbit

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(messages chan Message, o Override)

Publish Takes stream of messages and publish them to rabbit

type Verify

type Verify struct {
	Tag      uint64
	MultiAck bool
}

Verify will be used to Ack Message from the queue