Documentation ¶
Index ¶
Constants ¶
View Source
const (
CONTENT_TYPE_JSON = "application/json"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
type EventBus interface { // Start receiving events. Events are distributed in the current consumer-group, so not every consumer receives all events. Subscribe(eventName, consumerGroup string, autoAck bool) (Subscription, error) // Stops all subscribes and closes all internal connections Close() error // Publish sends the given payload to all consumers subscribed to the given event. Publish(eventName string, payload interface{}) error }
func NewAmqpEventBus ¶
type Subscription ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.