broker

Documentation

Index

• type Broker
• type Handler
• type Logger
• type Message

Types

type Broker

type Broker interface {
	Subscribe(event string, h Handler) error
	Publish(msg Message, queue string) error
}

type Handler

type Handler func(msg Message) (bool, error)

callback to handling messages

type Logger

type Logger interface {
	Fatalf(tpl string, args ...interface{})
	Errorf(tpl string, args ...interface{})
}

type Message

type Message struct {
	Body    []byte
	Headers map[string]interface{}
}

AMQP message