1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
package amqp
import (
"github.com/NeowayLabs/wabbit"
"github.com/streadway/amqp"
)
type Delivery struct {
*amqp.Delivery
}
func (d *Delivery) Body() []byte {
return d.Delivery.Body
}
func (d *Delivery) Headers() wabbit.Option {
return wabbit.Option(d.Delivery.Headers)
}
func (d *Delivery) DeliveryTag() uint64 {
return d.Delivery.DeliveryTag
}
func (d *Delivery) ConsumerTag() string {
return d.Delivery.ConsumerTag
}
func (d *Delivery) MessageId() string {
return d.Delivery.MessageId
}
|
