broker

Documentation

Index

• type Broker
• type Event
• type Handler
• type Message
• type Publisher
• type Subscriber

Types

type Broker

type Broker interface {
	Publisher
	Subscriber
	Initialize() error
	Disconnect() error
	Consume(group *sync.WaitGroup)
	HasConsumer() bool
}

Broker is the interface which defines the client connection(s) to a concrete broker like amqp

type Event

type Event interface {
	Message() *Message
	Ack()
	Nack(requeue bool)
	Reject(requeue bool)
	QueueName() string
	RoutingKey() string
	SetContext(ctx context.Context)
}

Event abstraction

type Handler

type Handler func(event Event)

type Message

type Message struct {
	Context context.Context
	Body    []byte
}

Message is the core structure of the broker. It abstract's away the concrete broker message implementations (e.g. amqp.Delivery).

type Publisher

type Publisher interface {
	Publish(exchange, routingKey string, message *Message) error
	EnsureExchange(exchange string)
}

Publisher can publish messages with a routingKey to the message-broker

type Subscriber

type Subscriber interface {
	Subscribe(exchange, routingKey string, handler Handler) error
}

Subscriber can subscribe to exchanges with a routingKey