amqp

type Publisher ¶ added in v0.1.4

type Publisher struct {
	amqp.Publishing

	Exchange string
	Queue    string
	Type     string
	Data     interface{}
}

func (p Publisher) Publish() error

type Session ¶ added in v0.0.64

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() *Session

func (session *Session) Close() error

func (session *Session) Stream() error