rabbitmq

Documentation

Index

• type RabbitMQ
  • func (d *RabbitMQ) Cleanup() error
  • func (d *RabbitMQ) ClearWork() error
  • func (d *RabbitMQ) GetWork() (io.Reader, error)
  • func (d *RabbitMQ) HandleFailure() error
  • func (d *RabbitMQ) Init() error
  • func (d *RabbitMQ) LoadEnv(prefix string) error
  • func (d *RabbitMQ) LoadFlags() error

Types

type RabbitMQ

type RabbitMQ struct {
	Client *amqp.Connection
	URL    string
	Queue  string
}

func (*RabbitMQ) Cleanup

func (d *RabbitMQ) Cleanup() error

func (*RabbitMQ) ClearWork

func (d *RabbitMQ) ClearWork() error

func (*RabbitMQ) GetWork

func (d *RabbitMQ) GetWork() (io.Reader, error)

func (*RabbitMQ) HandleFailure

func (d *RabbitMQ) HandleFailure() error

func (*RabbitMQ) Init

func (d *RabbitMQ) Init() error

func (*RabbitMQ) LoadEnv

func (d *RabbitMQ) LoadEnv(prefix string) error

func (*RabbitMQ) LoadFlags

func (d *RabbitMQ) LoadFlags() error