messengers

Documentation

Index

• type Broker
• type Messenger
  • func New(debug bool, broker Broker) *Messenger
  • func (m *Messenger) Consume(queueName string) (<-chan *message.Message, error)
  • func (m *Messenger) Publish(queueName string, data []byte) error

Types

type Broker

type Broker interface {
	Publish(queueName string, payload message.Payload) error
	Consume(queueName string) (<-chan *message.Message, error)
}

type Messenger

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

func New

func New(debug bool, broker Broker) *Messenger

func (*Messenger) Consume

func (m *Messenger) Consume(queueName string) (<-chan *message.Message, error)

func (*Messenger) Publish

func (m *Messenger) Publish(queueName string, data []byte) error