README
¶
amqp-helpers
amqp lib helpers for golang
License
MIT © zcong1993
Documentation
¶
Index ¶
- func CopyMsgToPublishing(msg amqp.Delivery) *amqp.Publishing
- func MustBindQueue(ch *amqp.Channel, exchange, qName string, routerKeys []string, args amqp.Table)
- func MustDeclareConn(url string) *amqp.Connection
- func MustDeclareConsumer(ch *amqp.Channel, exchange, qName string, routerKeys []string, args amqp.Table) (*amqp.Channel, <-chan amqp.Delivery)
- func MustDeclareExchange(conn *amqp.Connection, exchange string, args amqp.Table) *amqp.Channel
- type AmqpDeath
- type Headers
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CopyMsgToPublishing ¶
func CopyMsgToPublishing(msg amqp.Delivery) *amqp.Publishing
CopyMsgToPublishing copy an Delivery msg into Publishing
func MustBindQueue ¶
MustBindQueue bind queue to exchange or die
func MustDeclareConn ¶
func MustDeclareConn(url string) *amqp.Connection
MustDeclareConn create a connection or die
func MustDeclareConsumer ¶
func MustDeclareConsumer(ch *amqp.Channel, exchange, qName string, routerKeys []string, args amqp.Table) (*amqp.Channel, <-chan amqp.Delivery)
MustDeclareConsumer declare a consumer delivery chan or die
func MustDeclareExchange ¶
MustDeclareExchange declare an exchange channel or die
Types ¶
type AmqpDeath ¶
type AmqpDeath struct {
Count int `json:"count"`
Exchange string `json:"exchange"`
OriginalExpiration string `json:"original-expiration"`
Queue string `json:"queue"`
Reason string `json:"reason"`
RoutingKeys []string `json:"routing-keys"`
Time time.Time `json:"time"`
}
AmqpDeath is struct of "x-death" header
func ParseDeathHeader ¶
ParseDeathHeader parse "x-death" header from raw
Source Files
Click to show internal directories.
Click to hide internal directories.