queue

Documentation

Index

• Variables
• type Message
• type MessageBody
• type Queue
• type RabbitMQ
  • func (c *RabbitMQ) BindQueue(key string) (q amqp.Queue, err error)
  • func (c *RabbitMQ) Close() error
  • func (c *RabbitMQ) Connect() error
  • func (c *RabbitMQ) HandleConsumedDeliveries(key string, handle func(payload map[string]interface{}) error)
  • func (c *RabbitMQ) Publish(key string, message []byte, attempts int32) error
  • func (c *RabbitMQ) Reconnect() error

Variables

var (
	ProcessSyncLog = "log.insert"
	ProcessExample = "example.consumer"
)

Types

type Message

type Message struct {
	Queue         string
	ReplyTo       string
	ContentType   string
	CorrelationID string
	Priority      uint8
	Body          MessageBody
}

type MessageBody

type MessageBody struct {
	Data []byte
	Type string
}

type Queue

type Queue interface {
	Connect() error
	Close() error
	BindQueue(key string) (q amqp.Queue, err error)
	Reconnect() error
	HandleConsumedDeliveries(key string, handle func(payload map[string]interface{}) error)
	Publish(key string, message []byte, attempts int32) error
}

type RabbitMQ

type RabbitMQ struct {
	Ctx        context.Context
	Uri        string
	Exchange   string
	Kind       string
	Prefix     string
	RetryCount int
	Err        chan error
	// contains filtered or unexported fields
}

func (*RabbitMQ) BindQueue

func (c *RabbitMQ) BindQueue(key string) (q amqp.Queue, err error)

func (*RabbitMQ) Close

func (c *RabbitMQ) Close() error

func (*RabbitMQ) Connect

func (c *RabbitMQ) Connect() error

func (*RabbitMQ) HandleConsumedDeliveries

func (c *RabbitMQ) HandleConsumedDeliveries(key string, handle func(payload map[string]interface{}) error)

func (*RabbitMQ) Publish

func (c *RabbitMQ) Publish(key string, message []byte, attempts int32) error

Publisher Things

func (*RabbitMQ) Reconnect

func (c *RabbitMQ) Reconnect() error