communicator

Documentation

Index

• Variables
• type Communicator
  • func NewCommunicator(cnf *MessageBusConfig) *Communicator
  • func (communicator *Communicator) Publish(msg *SendMessage) error
  • func (communicator *Communicator) StartConsuming(consumerTag string, taskProcessor TaskProcessor) (bool, error)
  • func (communicator *Communicator) StopConsuming()
• type MessageBusConfig
• type TaskProcessor

Variables

var RetryClosure = func() {
	retryIn := 2
	log.Printf("Retrying to connect RabbitMQ in %v seconds", retryIn)
	time.Sleep(time.Second)
}

Types

type Communicator

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

Communicator represents an AMQP broker

func NewCommunicator

func NewCommunicator(cnf *MessageBusConfig) *Communicator

func (*Communicator) Publish

func (communicator *Communicator) Publish(msg *SendMessage) error

Publish places a new message on the default queue

func (*Communicator) StartConsuming

func (communicator *Communicator) StartConsuming(consumerTag string, taskProcessor TaskProcessor) (bool, error)

StartConsuming enters a loop and waits for incoming messages

func (*Communicator) StopConsuming

func (communicator *Communicator) StopConsuming()

StopConsuming quits the loop

type MessageBusConfig

type MessageBusConfig struct {
	Broker       string
	Exchange     string
	ExchangeType string
	DefaultQueue string
	BindingKeys  []string
}

Config holds all configuration for our program

type TaskProcessor

type TaskProcessor interface {
	Process(msg *RecvMessage) error
}