queue

Documentation

Index

• Constants
• type Queue
  • func NewQueue(url string) (*Queue, error)
  • func NewQueueWithParams(url string, exchangeName string, noWait bool) (*Queue, error)
  • func (q *Queue) DeclareDeadLetterQueue(key string) error
  • func (q *Queue) DeclareQueue(name string) error
  • func (q *Queue) GetChannelNotify() chan *amqp.Error
  • func (q *Queue) GetChannelReturn() chan amqp.Return
  • func (q *Queue) GetConnNotify() chan *amqp.Error
  • func (q *Queue) GetDLMsg() (<-chan amqp.Delivery, error)
  • func (q *Queue) GetMsg() (<-chan amqp.Delivery, error)
  • func (q *Queue) GetMsgWithManualAck() (<-chan amqp.Delivery, error)
  • func (q *Queue) GetQueueName() string
  • func (q *Queue) Publish(key string, body []byte) error
  • func (q *Queue) Reconnect() error
  • func (q *Queue) SendDeadLetter(key string, body []byte, retry_count int32) error
  • func (q *Queue) Subscribe(key string) error

Constants

const (
	QUEUE_NAME           = "database_topics"
	EXCHANGE             = "all_actions"
	DEAD_LETTER_EXCHANGE = "dl_all_actions"
	EXCHANGE_IMPORT      = "data_migration"
)

Types

type Queue

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

RabbitMQ client

func NewQueue

func NewQueue(url string) (*Queue, error)

func NewQueueWithParams

func NewQueueWithParams(url string, exchangeName string, noWait bool) (*Queue, error)

func (*Queue) DeclareDeadLetterQueue

func (q *Queue) DeclareDeadLetterQueue(key string) error

func (*Queue) DeclareQueue

func (q *Queue) DeclareQueue(name string) error

func (*Queue) GetChannelNotify

func (q *Queue) GetChannelNotify() chan *amqp.Error

func (*Queue) GetChannelReturn

func (q *Queue) GetChannelReturn() chan amqp.Return

func (*Queue) GetConnNotify

func (q *Queue) GetConnNotify() chan *amqp.Error

func (*Queue) GetDLMsg

func (q *Queue) GetDLMsg() (<-chan amqp.Delivery, error)

func (*Queue) GetMsg

func (q *Queue) GetMsg() (<-chan amqp.Delivery, error)

func (*Queue) GetMsgWithManualAck

func (q *Queue) GetMsgWithManualAck() (<-chan amqp.Delivery, error)

func (*Queue) GetQueueName

func (q *Queue) GetQueueName() string

func (*Queue) Publish

func (q *Queue) Publish(key string, body []byte) error

func (*Queue) Reconnect

func (q *Queue) Reconnect() error

func (*Queue) SendDeadLetter

func (q *Queue) SendDeadLetter(key string, body []byte, retry_count int32) error

func (*Queue) Subscribe

func (q *Queue) Subscribe(key string) error