rabbitmq

Documentation

Index

• type IBroker
  • func Get() *IBroker
  • func Init(dsn string) (*IBroker, error)
  • func (b *IBroker) ConnQueue(queue string) (<-chan amqp.Delivery, error)
  • func (b *IBroker) InitQueue(queue string) error
  • func (b *IBroker) SendToQueue(queue string, message amqp.Publishing) error

Types

type IBroker

type IBroker struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

func Get

func Get() *IBroker

func Init

func Init(dsn string) (*IBroker, error)

func (*IBroker) ConnQueue

func (b *IBroker) ConnQueue(queue string) (<-chan amqp.Delivery, error)

func (*IBroker) InitQueue

func (b *IBroker) InitQueue(queue string) error

func (*IBroker) SendToQueue

func (b *IBroker) SendToQueue(queue string, message amqp.Publishing) error