Versions in this module Expand all Collapse all v0 v0.3.6 Oct 7, 2021 Changes in this version + type EventBus struct + func NewEventBus(brokerDSN, queue, exchange, connectionName string) *EventBus + func (bus *EventBus) DeleteQueue(name string) error + func (bus *EventBus) PublishEvents(events []*goengine.DomainMessage) error + func (bus *EventBus) ReceiveEvents(options goengine.VersionedEventReceiverOptions) error + type RawVersionedEvent struct + ID string + Payload json.RawMessage + RecordedOn time.Time + Type string + Version int
Go to main page