queues

Documentation

Index

• type RabbitMQConnection
  • func NewRabbitMQConnection(conn *amqp.Connection) *RabbitMQConnection
  • func (c *RabbitMQConnection) ConsumeQueueWithChannel(queue string, ch *amqp.Channel) (<-chan amqp.Delivery, error)
  • func (c *RabbitMQConnection) PublishEventsTrackingTask(payload []byte) error

Types

type RabbitMQConnection

type RabbitMQConnection struct {
	amqp.Connection
}

RabbitMQConnection wrapper around amqp.Connection

func NewRabbitMQConnection

func NewRabbitMQConnection(conn *amqp.Connection) *RabbitMQConnection

NewRabbitMQConnection initializes a wrapper around an amqp.Connection

func (*RabbitMQConnection) ConsumeQueueWithChannel

func (c *RabbitMQConnection) ConsumeQueueWithChannel(queue string, ch *amqp.Channel) (<-chan amqp.Delivery, error)

ConsumeQueueWithChannel consumes a RabbitMQConnection queue with predefined settings from a provided amqp.Channel

func (*RabbitMQConnection) PublishEventsTrackingTask

func (c *RabbitMQConnection) PublishEventsTrackingTask(payload []byte) error

PublishEventsTrackingTask publishes a json payload to the tracking exchange