1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
package amqp
import "github.com/streadway/amqp"
// Queue is a wrapper for "streadway/amqp".Queue but implementing
// the wabbit.Queue interface.
type Queue struct {
*amqp.Queue
}
// Messages returns the count of messages not awaiting acknowledgment
func (q *Queue) Messages() int {
return q.Queue.Messages
}
// Name of the queue
func (q *Queue) Name() string {
return q.Queue.Name
}
// Consumers returns the amount of consumers of this queue
func (q *Queue) Consumers() int {
return q.Queue.Consumers
}
|
