amqp

Documentation

Overview

Package amqp holds code required for reading messages from RabbitMQ.

Index

• type Connection
  • func NewConnection(dsn string, initQueues InitQueuesHandler) (*Connection, error)
  • func (c *Connection) Close() error
• type InitQueuesHandler
  • func NewQueuesHandler(pipes []config.Pipe, handler MessageHandler, statsClient client.Client) InitQueuesHandler
• type MessageHandler

Types

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

Connection struct holds data for AMQP connection

func NewConnection

func NewConnection(dsn string, initQueues InitQueuesHandler) (*Connection, error)

NewConnection instantiates and establishes new AMQP connection

func (*Connection) Close

func (c *Connection) Close() error

Close closes AMQP connection

type InitQueuesHandler

type InitQueuesHandler func(conn *amqp.Connection) error

InitQueuesHandler is a handler function type for AMQP connection

func NewQueuesHandler

func NewQueuesHandler(pipes []config.Pipe, handler MessageHandler, statsClient client.Client) InitQueuesHandler

NewQueuesHandler instantiates queues initialisation handler

type MessageHandler

type MessageHandler func(body []byte, pipe config.Pipe) error

MessageHandler is a handler function type for consumed messages