bus

Documentation

Index

• type RabbitmqBus
  • func NewRabbitmqBus(logger logger.Logger, consumerFactory consumercontracts.ConsumerFactory, ...) (RabbitmqBus, error)

Types

type RabbitmqBus

type RabbitmqBus interface {
	bus.Bus
	consumerConfigurations.RabbitMQConsumerConnector
}

func NewRabbitmqBus

func NewRabbitmqBus(
	logger logger.Logger,
	consumerFactory consumercontracts.ConsumerFactory,
	producerFactory producercontracts.ProducerFactory,
	rabbitmqBuilderFunc configurations.RabbitMQConfigurationBuilderFuc,
) (RabbitmqBus, error)