rabbitmq

Documentation

Index

• type Listener
  • func NewListener(addr, queue string) (*Listener, error)
  • func (r *Listener) Close() error
  • func (r *Listener) Listen() (<-chan amqp.Delivery, error)
• type Publisher
  • func NewPublisher(addr, queue string) (*Publisher, error)
  • func (r *Publisher) Close() error
  • func (r *Publisher) Publish(body []byte, contentType string) error

Types

type Listener

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

func NewListener

func NewListener(addr, queue string) (*Listener, error)

func (*Listener) Close

func (r *Listener) Close() error

func (*Listener) Listen

func (r *Listener) Listen() (<-chan amqp.Delivery, error)

type Publisher

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

func NewPublisher

func NewPublisher(addr, queue string) (*Publisher, error)

func (*Publisher) Close

func (r *Publisher) Close() error

func (*Publisher) Publish

func (r *Publisher) Publish(body []byte, contentType string) error