amqp

Documentation

Index

• type Queue
  • func NewAmqpConnection(connstring string, queueNames []string) (Queue, error)
  • func (q Queue) ConsumerMessageFromQueue(message string, queueName string) ([]interface{}, error)
  • func (q Queue) SendMessageToQueue(message string, queueName string) error

Types

type Queue

type Queue struct {
	AmqpConnection *amqp.Connection
	Channel        *amqp.Channel
	Entities       map[string]amqp.Queue
}

Queues is an entity witholding connections to queues and references to channels/queues

func NewAmqpConnection

func NewAmqpConnection(connstring string, queueNames []string) (Queue, error)

NewAmqpConnection takes a set of queue names, creates those channels, and establishes connections to such queues

func (Queue) ConsumerMessageFromQueue

func (q Queue) ConsumerMessageFromQueue(message string, queueName string) ([]interface{}, error)

ConsumerMessageFromQueue consumes messages from queues

func (Queue) SendMessageToQueue

func (q Queue) SendMessageToQueue(message string, queueName string) error

SendMessageToQueue sends messages to queues