events

Documentation

Index

• type RabbitMQBroker
  • func (rmq *RabbitMQBroker) Publish(message []byte) error
• type RabbitMQBrokerInterface

Types

type RabbitMQBroker

type RabbitMQBroker struct {
	QueueName  string
	Connection *amqp.Connection
	Logger     *logrus.Entry
}

func (*RabbitMQBroker) Publish

func (rmq *RabbitMQBroker) Publish(message []byte) error

type RabbitMQBrokerInterface

type RabbitMQBrokerInterface interface {
	Publish(message []byte) error
}