rabbitmq

Documentation

Index

• type RabbitMQ
  • func (d *RabbitMQ) Cleanup() error
  • func (d *RabbitMQ) Init() error
  • func (d *RabbitMQ) LoadEnv(prefix string) error
  • func (d *RabbitMQ) LoadFlags() error
  • func (d *RabbitMQ) Push(r io.Reader) error

Types

type RabbitMQ

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

func (*RabbitMQ) Cleanup

func (d *RabbitMQ) Cleanup() 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

func (*RabbitMQ) Push

func (d *RabbitMQ) Push(r io.Reader) error