Make server queue non-auto-delete

vibhavp · Mar 6, 2016 · 930e5e1 · 930e5e1
1 parent c7221d4
commit 930e5e1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/client.go b/client.go
@@ -95,7 +95,10 @@ func NewClientCodec(conn *amqp.Connection, serverRouting string, encodingCodec E
 		return nil, err
 	}
 
-	serverQueue, _ := channel.QueueDeclare(serverRouting, false, true, false, false, nil)
+	serverQueue, err := channel.QueueDeclare(serverRouting, false, false, false, false, nil)
+	if err != nil {
+		return nil, err
+	}
 	if serverQueue.Consumers == 0 {
 		return nil, ErrNoConsumers
 	}

diff --git a/server.go b/server.go
@@ -91,7 +91,7 @@ func NewServerCodec(conn *amqp.Connection, serverRouting string, encodingCodec E
 		return nil, err
 	}
 
-	queue, err := channel.QueueDeclare(serverRouting, true, false, false, false, nil)
+	queue, err := channel.QueueDeclare(serverRouting, false, false, false, false, nil)
 	if err != nil {
 		return nil, err
 	}