|
|
|
@ -43,7 +43,7 @@ func (s *server) SubscribeTo(exhangeName string, queueName string, routingKey st |
|
|
|
queueName, // name
|
|
|
|
queueName, // name
|
|
|
|
true, // durable
|
|
|
|
true, // durable
|
|
|
|
true, // delete when unused
|
|
|
|
true, // delete when unused
|
|
|
|
queueName != "", // exclusive
|
|
|
|
queueName == "", // exclusive
|
|
|
|
false, // no-wait
|
|
|
|
false, // no-wait
|
|
|
|
nil, // arguments
|
|
|
|
nil, // arguments
|
|
|
|
) |
|
|
|
) |
|
|
|
@ -74,7 +74,7 @@ func (s *server) SubscribeTo(exhangeName string, queueName string, routingKey st |
|
|
|
q.Name, // queue
|
|
|
|
q.Name, // queue
|
|
|
|
"", // consumer
|
|
|
|
"", // consumer
|
|
|
|
true, // auto-ack
|
|
|
|
true, // auto-ack
|
|
|
|
queueName != "", // exclusive
|
|
|
|
queueName == "", // exclusive
|
|
|
|
false, // no-local
|
|
|
|
false, // no-local
|
|
|
|
false, // no-wait
|
|
|
|
false, // no-wait
|
|
|
|
nil, // args
|
|
|
|
nil, // args
|
|
|
|
|
