amqpfeed

README

AMQP Eventfeed for straumur

Eventfeed for straumur

Documentation

Index

• type Consumer
  • func NewConsumer(amqpURI, exchange, exchangeType, queueName, key, ctag string, ...) (*Consumer, error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Updates() <-chan straumur.Event

Types

type Consumer

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

func NewConsumer

func NewConsumer(amqpURI, exchange, exchangeType, queueName, key, ctag string, durable, auto_delete bool) (*Consumer, error)

TODO: Document different usage of queues.

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Updates

func (c *Consumer) Updates() <-chan straumur.Event