bus

Documentation

Index

• func NewFowarder(bus MessageQueue, eventTypes []string) eventmanager.Subscriber
• type Envelope
• type Header
• type Message
• type MessageQueue

Functions

func NewFowarder

func NewFowarder(
	bus MessageQueue,
	eventTypes []string,
) eventmanager.Subscriber

NewFowarder fowards all voting events to a message queue.

Types

type Envelope

type Envelope struct {
	Header Header           `json:"header,omitempty"`
	Body   *json.RawMessage `json:"body,omitempty"`
}

Envelope wraps a before sending it across the wire

type Header

type Header map[string]string

Header simple dictionary of string keys string values for housing message meta-data

type Message

type Message interface {
	Event() eventstore.Event
	Header() Header
}

Message is passed back to recieved and expected to go back to Ack or Nak

type MessageQueue

type MessageQueue interface {
	Receive() (Message, error)
	Ack(Message) error
	Nack(Message) error
	Send(eventstore.Event) error
}

MessageQueue send and retreive events ove a message queue