queue

Documentation

Index

• Variables
• func NewRabbitMqModule(provider common.ConfigProvider) (common.Module, error)
• type Identity
  • func (id *Identity) GetModule(factory common.Factory) (Module, error)
• type Module
  • func NewRabbitMq(boxConfig common.BoxConfig, connConfiguration connection.Config, ...) (Module, error)

Variables

var ModuleID = &Identity{}

Functions

func NewRabbitMqModule

func NewRabbitMqModule(provider common.ConfigProvider) (common.Module, error)

Types

type Identity

type Identity struct{}

func (*Identity) GetModule

func (id *Identity) GetModule(factory common.Factory) (Module, error)

type Module

type Module interface {
	common.Module
	GetEventRouter() event.Router
	GetMessageRouter() message.Router
}

func NewRabbitMq

func NewRabbitMq(
	boxConfig common.BoxConfig,
	connConfiguration connection.Config,
	queueConfiguration queue.RouterConfig,
) (Module, error)