rmqproducer

Documentation

Index

• func NewConnection() (*rabbitmq.Conn, error)
• func NewPublisher(conn *rabbitmq.Conn) (*rabbitmq.Publisher, error)
• type Publisher

Functions

func NewConnection

func NewConnection() (*rabbitmq.Conn, error)

Init a new RabbitMQ connection with the RabbitMQ host.

func NewPublisher

func NewPublisher(conn *rabbitmq.Conn) (*rabbitmq.Publisher, error)

Create a new publisher that publishes to the "swipes" exchange via "fanout" method.

Types

type Publisher

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