publisher

Documentation

Index

• func ClosePublisher(publisher Publisher, log logger.Logger)
• type Publisher
  • func NewPublisher(conf config.QueueConfig, log logger.Logger) (Publisher, error)

Functions

func ClosePublisher

func ClosePublisher(publisher Publisher, log logger.Logger)

Types

type Publisher

type Publisher interface {
	io.Closer
	Publish(
		data []byte,
		routingKeys []string,
		optionFuncs ...func(*rabbitmq.PublishOptions),
	) error
}

Publisher is just an interface for the library publisher which doesn't have one.

func NewPublisher

func NewPublisher(conf config.QueueConfig, log logger.Logger) (Publisher, error)

NewPublisher creates a publisher and connects to the rabbit under the hood. This method appears to be not testable cause it combines 2 responsibilities: create an instance and connect to a queue. I think we may rely on NewPublisher has been already tested in the library.