producer

Documentation

Index

• func NewProducerFactory(rabbitmqOptions *config.RabbitmqOptions, connection types2.IConnection, ...) producercontracts.ProducerFactory
• func NewRabbitMQProducer(cfg *config.RabbitmqOptions, connection types.IConnection, ...) (producer.Producer, error)

Functions

func NewProducerFactory

func NewProducerFactory(
	rabbitmqOptions *config.RabbitmqOptions,
	connection types2.IConnection,
	eventSerializer serializer.MessageSerializer,
	l logger.Logger,
) producercontracts.ProducerFactory

func NewRabbitMQProducer

func NewRabbitMQProducer(
	cfg *config.RabbitmqOptions,
	connection types.IConnection,
	rabbitmqProducersConfiguration map[string]*configurations.RabbitMQProducerConfiguration,
	logger logger.Logger,
	eventSerializer serializer.MessageSerializer,
	isProducedNotifications ...func(message types2.IMessage),
) (producer.Producer, error)