Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitmqBus ¶
type RabbitmqBus interface { bus.Bus consumerConfigurations.RabbitMQConsumerConnector }
func NewRabbitmqBus ¶
func NewRabbitmqBus( cfg *config.RabbitmqOptions, serializer serializer.EventSerializer, logger logger.Logger, connection types2.IConnection, rabbitmqBuilderFunc configurations.RabbitMQConfigurationBuilderFuc, ) (RabbitmqBus, error)
Click to show internal directories.
Click to hide internal directories.