queues

Documentation

Index

• func DeleteQueue(ch *amqp.Channel, q QueueStruct) error
• func NewQueue(ch *amqp.Channel, q QueueStruct) (*amqp.Queue, error)
• type QueueStruct

Functions

func DeleteQueue

func DeleteQueue(ch *amqp.Channel, q QueueStruct) error

Deletes a queue, duh

func NewQueue

func NewQueue(ch *amqp.Channel, q QueueStruct) (*amqp.Queue, error)

Translates your queue from readable struct to efficient queue declaration

Types

type QueueStruct

type QueueStruct struct {
	Name           string
	Durable        bool
	DeleteOnUnused bool
	Exclusive      bool
	NoWait         bool
	Args           amqp.Table
}

Queue struct for readability(no real point)