Alvaro Videla avatar Alvaro Videla committed 1314aac

fixes queue option usage

Comments (0)

Files changed (1)

 function getConsumer(conn, exchangeName, queueName, routingKey, callback) {
     var exchange = {
         name: exchangeName,
-        opts: { durable: true, type: 'direct', auto_delete: false}
+        opts: { durable: true, type: 'direct', autoDelete: false}
     };
 
     var queue = {
         name: queueName,
-        opts: {exclusive: false, durable: true, auto_delete: false}
+        opts: {exclusive: false, durable: true, autoDelete: false}
     };
     
     installCallback(conn, exchange, queue, routingKey, callback);
 function getAnonConsumer(conn, exchangeName, queueName, routingKey, callback) {
     var exchange = {
         name: exchangeName,
-        opts: { durable: true, type: 'fanout', auto_delete: false}
+        opts: { durable: true, type: 'fanout', autoDelete: false}
     };
 
     var queue = {
         name: queueName,
-        opts: {exclusive: true, durable: false, auto_delete: true}
+        opts: {exclusive: true, durable: false, autoDelete: true}
     };
     
     installCallback(conn, exchange, queue, routingKey, callback);
     services.getRabbitMqConnection(function(conn) {
         var exchange = {
             name: exchangeName,
-            opts: { durable: true, type: 'direct', auto_delete: false}
+            opts: { durable: true, type: 'direct', autoDelete: false}
         };
         var ex = conn.exchange(exchange.name, exchange.opts, function(ex) {
             ex.publish(routingKey, msg, {deliveryMode: 1});
     services.getRabbitMqConnection(function(conn) {
         var exchange = {
             name: exchangeName,
-            opts: { durable: true, type: 'fanout', auto_delete: false}
+            opts: { durable: true, type: 'fanout', autoDelete: false}
         };
         var ex = conn.exchange(exchange.name, exchange.opts, function(ex) {
             ex.publish(routingKey, msg, {deliveryMode: 1});
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for ProjectModifiedEvent.java.
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.