rabbitmq

Documentation

Index

• type Publisher
• type QueuePublisher
  • func NewQueuePublisher(rabbitMQURL string, queueName string) *QueuePublisher
  • func NewQueuePublisherWithConnection(rabbitMQURL string, conn *amqp091.Connection, queueName string) (*QueuePublisher, error)
  • func (q *QueuePublisher) Publish(msg amqp091.Publishing) error

Types

type Publisher

type Publisher interface {
	Publish(msg amqp091.Publishing) error
}

type QueuePublisher

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

func NewQueuePublisher

func NewQueuePublisher(rabbitMQURL string, queueName string) *QueuePublisher

func NewQueuePublisherWithConnection

func NewQueuePublisherWithConnection(
	rabbitMQURL string,
	conn *amqp091.Connection,
	queueName string,
) (*QueuePublisher, error)

func (*QueuePublisher) Publish

func (q *QueuePublisher) Publish(msg amqp091.Publishing) error