Documentation ¶
Index ¶
- Variables
- func DeclareExchanges(exchanges []string, kind string, durable bool, autoDelete bool, internal bool, ...) error
- func DeclareQueues(queues []string, durable bool, autoDelete bool, exclusive bool, noWait bool, ...) error
- func Listen(listenMap map[string]GenericFN, prefetch int)
- func ProcessDeadLetter(payload []byte) error
- func PublishToExchange(exchangeName string, data interface{}) error
- func PublishToQueue(queueName string, data interface{}) error
- func SetDeadLetterQueue(queueName string)
- type Channel
- type Connection
- type GenericFN
Constants ¶
This section is empty.
Variables ¶
View Source
var DeadLetterQueue string
Functions ¶
func DeclareExchanges ¶
func DeclareQueues ¶
func ProcessDeadLetter ¶
func PublishToExchange ¶
func PublishToQueue ¶
func SetDeadLetterQueue ¶
func SetDeadLetterQueue(queueName string)
Types ¶
type Channel ¶
Channel amqp.Channel wapper
func GetChannel ¶
func GetChannel() *Channel
type Connection ¶
type Connection struct {
*amqp.Connection
}
Connection amqp.Connection wrapper
func Dial ¶
func Dial(url string) (*Connection, error)
Dial wrap amqp.Dial, dial and get a reconnect connection
func GetConnection ¶
func GetConnection() *Connection
func (*Connection) Channel ¶
func (c *Connection) Channel() (*Channel, error)
Channel wrap amqp.Connection.Channel, get a auto reconnect channel
Click to show internal directories.
Click to hide internal directories.