amqp

Documentation

Index

• type Consumer
  • func NewConsumer(uri, exchange, exchangeType, queueName, key, ctag string) (*Consumer, error)
  • func (c *Consumer) Shutdown() error
• type Producer
  • func NewProducer(uri, exchange, exchangeType, routingKey string, reliable bool) (*Producer, error)
  • func (this *Producer) Close() error
  • func (this *Producer) Send(data []byte) error

Types

type Consumer

type Consumer struct {
	Uri          string //amqp://guest:guest@localhost:5672/
	ExchangeName string // "test-exchange"
	ExchangeType string // "direct", "Exchange type - direct|fanout|topic|x-custom"
	QueueName    string //("test-key", "AMQP routing key"
	BindingKey   string
	ReceiveFunc  func(data []byte)
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(uri, exchange, exchangeType, queueName, key, ctag string) (*Consumer, error)

func (*Consumer) Shutdown

func (c *Consumer) Shutdown() error

type Producer

type Producer struct {
	Uri          string //amqp://guest:guest@localhost:5672/
	ExchangeName string // "test-exchange"
	ExchangeType string // "direct", "Exchange type - direct|fanout|topic|x-custom"
	RoutingKey   string //("test-key", "AMQP routing key"
	Reliable     bool
	SuccessFunc  func(confirms *amqp.Confirmation) // "Wait for the publisher confirmation before exiting"
	FailFunc     func(confirms *amqp.Confirmation)
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer(uri, exchange, exchangeType, routingKey string, reliable bool) (*Producer, error)

func (*Producer) Close

func (this *Producer) Close() error

func (*Producer) Send

func (this *Producer) Send(data []byte) error