rabbitmq

Documentation

Index

• type CommandBus
  • func NewCommandBus(connectionURL string) (*CommandBus, error)
  • func (c *CommandBus) Close() error
  • func (c *CommandBus) Dispatch(ctx context.Context, command command.Command) error
  • func (c *CommandBus) Register(t command.Type, handler command.Handler)
• type EventBus
  • func NewEventBus(connectionURL string) (*EventBus, error)
  • func (b *EventBus) Close() error
  • func (b *EventBus) Publish(ctx context.Context, events []event.Event) error
  • func (b *EventBus) Subscribe(evtType event.Type, handler event.Handler)

Types

type CommandBus

type CommandBus struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

func NewCommandBus

func NewCommandBus(connectionURL string) (*CommandBus, error)

func (*CommandBus) Close

func (c *CommandBus) Close() error

func (*CommandBus) Dispatch

func (c *CommandBus) Dispatch(ctx context.Context, command command.Command) error

func (*CommandBus) Register

func (c *CommandBus) Register(t command.Type, handler command.Handler)

type EventBus

type EventBus struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

EventBus is an in-memory implementation of the event.Bus.

func NewEventBus

func NewEventBus(connectionURL string) (*EventBus, error)

NewEventBus initializes a new EventBus.

func (*EventBus) Close

func (b *EventBus) Close() error

func (*EventBus) Publish

func (b *EventBus) Publish(ctx context.Context, events []event.Event) error

Publish implements the event.Bus interface.

func (*EventBus) Subscribe

func (b *EventBus) Subscribe(evtType event.Type, handler event.Handler)

Subscribe implements the event.Bus interface.