amqp

Documentation

Index

• func AddService(config service.Config)
• func Start()
• func Stop() error
• type Publisher
  • func (p Publisher) Publish() error
• type Session
  • func NewSession() *Session
  • func (session *Session) Close() error
  • func (session *Session) Stream() error

Functions

func AddService

func AddService(config service.Config)

func Start

func Start()

func Stop

func Stop() error

Types

type Publisher

type Publisher struct {
	amqp.Publishing

	Exchange string
	Queue    string
	Type     string
	Data     interface{}
}

func (Publisher) Publish

func (p Publisher) Publish() error

Publish will push data onto the queue

type Session

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

This exports a Session object that wraps this library. It automatically reconnects when the connection fails, and blocks all pushes until the connection succeeds. It also confirms every outgoing message, so none are lost. It doesn't automatically ack each message, but leaves that to the parent process, since it is usage-dependent.

Try running this in one terminal, and `rabbitmq-server` in another. Stop & restart RabbitMQ to see how the queue reacts.

func NewSession

func NewSession() *Session

New creates a new consumer state instance, and automatically attempts to connect to the server.

func (*Session) Close

func (session *Session) Close() error

Close will cleanly shutdown the channel and connection.

func (*Session) Stream

func (session *Session) Stream() error

Stream will continuously put queue items on the channel. It is required to call delivery.Ack when it has been successfully processed, or delivery.Nack when it fails. Ignoring this will cause data to build up on the server.