amqp

package

v0.2.3-0...-5ed8acd Latest Latest Go to latest Published: Apr 26, 2022 License: MIT Imports: 6 Imported by: 0

Details

Package amqp holds code required for reading messages from RabbitMQ.

This section is empty.

This section is empty.

This section is empty.

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

Connection struct holds data for AMQP connection

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

NewConnection instantiates and establishes new AMQP connection

func (c *Connection) Close() error

Close closes AMQP connection

type InitQueuesHandler func(conn *amqp.Connection) error

InitQueuesHandler is a handler function type for AMQP connection

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

NewQueuesHandler instantiates queues initialisation handler

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

MessageHandler is a handler function type for consumed messages