rabbit

Documentation

Index

• type RabbitMessageBroker
  • func NewRabbitMessageBroker(logger *zap.SugaredLogger, url string) (*RabbitMessageBroker, error)
  • func (r *RabbitMessageBroker) Close()
  • func (r *RabbitMessageBroker) PublishCommand(commandType string, body []byte) error

Types

type RabbitMessageBroker

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

func NewRabbitMessageBroker

func NewRabbitMessageBroker(logger *zap.SugaredLogger, url string) (*RabbitMessageBroker, error)

func (*RabbitMessageBroker) Close

func (r *RabbitMessageBroker) Close()

Close closes the connection to rabbitmq.

func (*RabbitMessageBroker) PublishCommand

func (r *RabbitMessageBroker) PublishCommand(commandType string, body []byte) error