-
Notifications
You must be signed in to change notification settings - Fork 0
/
declarations.go
79 lines (70 loc) · 1.96 KB
/
declarations.go
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package bcamqp
// ExchangeType specifies the type of the exchange to be created
type ExchangeType string
// Lists the different exchange types
const (
Direct ExchangeType = "direct"
Fanout ExchangeType = "fanout"
Topic ExchangeType = "topic"
Headers ExchangeType = "headers"
)
// ExchangeOptions holds options for exchange creation
type ExchangeOptions struct {
Name string
Type ExchangeType
Durable bool
}
// DeclareExchange makes sure that there is an exchange with the specified
// properties on the broker
//
// It returns an error when a exchange with the specified name already exists,
// but differs
func (b *Broker) DeclareExchange(options ExchangeOptions) error {
return b.mainChannel.ExchangeDeclare(
options.Name, // name
string(options.Type), // kind
options.Durable, // durable
!options.Durable, // autoDelete
false, // internal
false, // noWait
nil,
)
}
// QueueOptions holds options for queue creation
type QueueOptions struct {
Name string
Durable bool
Exclusive bool
}
// DeclareQueue makes sure that there is a queue with the specified properties
// on the broker
//
// It returns an error when a queue with the specified name already exisits,
// but differs
func (b *Broker) DeclareQueue(options QueueOptions) error {
_, err := b.mainChannel.QueueDeclare(
options.Name, // name
options.Durable, // durable
!options.Durable, // autoDelete
options.Exclusive, // exclusive
false, // noWait
nil,
)
return err
}
// BindingOptions holds options for binding creation
type BindingOptions struct {
Queue string
RoutingKey string
Exchange string
}
// DeclareBinding creates a binding between an exchange and a queue
func (b *Broker) DeclareBinding(options BindingOptions) error {
return b.mainChannel.QueueBind(
options.Queue, // name
options.RoutingKey, // key
options.Exchange, // exchange
false, // noWait
nil,
)
}