messageBroker

Documentation

Index

• type RabbitMQMessageBroker
  • func NewRabbitMQMessageBroker(logger *zap.Logger, config *viper.Viper) *RabbitMQMessageBroker
  • func (messageBroker *RabbitMQMessageBroker) Publish(exchangeName string, exchangeType string, key string, payload []byte)
  • func (messageBroker *RabbitMQMessageBroker) Subscribe(exchangeName string, exchangeType string, key string, queueName string)

Types

type RabbitMQMessageBroker

type RabbitMQMessageBroker struct {
	// contains filtered or unexported fields
}

func NewRabbitMQMessageBroker

func NewRabbitMQMessageBroker(logger *zap.Logger, config *viper.Viper) *RabbitMQMessageBroker

func (*RabbitMQMessageBroker) Publish

func (messageBroker *RabbitMQMessageBroker) Publish(exchangeName string, exchangeType string, key string, payload []byte)

func (*RabbitMQMessageBroker) Subscribe

func (messageBroker *RabbitMQMessageBroker) Subscribe(exchangeName string, exchangeType string, key string, queueName string)