rbitmq

Documentation

Index

• type Consumer
  • func NewConsumer(amqpServerUrl string, queueName string, queue chan amqp.Delivery, ...) *Consumer
  • func (c *Consumer) Start()
• type ConsumerCfg
• type Producer
  • func NewProducer(amqpServerUrl string, queueName string, queueSend chan amqp.Publishing, ...) *Producer
  • func (c *Producer) Start()
• type PublisherCfg

Types

type Consumer

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

func NewConsumer

func NewConsumer(amqpServerUrl string, queueName string, queue chan amqp.Delivery, cfg *ConsumerCfg) *Consumer

func (*Consumer) Start

func (c *Consumer) Start()

type ConsumerCfg

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

type Producer

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

func NewProducer

func NewProducer(amqpServerUrl string, queueName string, queueSend chan amqp.Publishing, cfg *PublisherCfg) *Producer

func (*Producer) Start

func (c *Producer) Start()

type PublisherCfg

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