From 9e7d9453a136e98970eeae042706680d0e974c67 Mon Sep 17 00:00:00 2001
From: abreits <abreits@gmail.com>
Date: Wed, 14 Oct 2015 15:09:10 +0200
Subject: [PATCH] amqplib: callback-api definition and tests added

---
 amqplib/amqplib-tests.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/amqplib/amqplib-tests.ts b/amqplib/amqplib-tests.ts
index c22bc7ac9..f99a3bde1 100644
--- a/amqplib/amqplib-tests.ts
+++ b/amqplib/amqplib-tests.ts
@@ -28,7 +28,7 @@ amqpcb.connect("amqp://localhost", (err, connection) => {
     if(!err) {
         connection.createChannel((err, channel) => {
           if (!err) {
-              channel.assertQueue("myQueue", (err, ok) => {
+              channel.assertQueue("myQueue", {}, (err, ok) => {
                   if(!err) {
                       channel.sendToQueue("myQueue", new Buffer(msg));
                   }
@@ -42,7 +42,7 @@ amqpcb.connect("amqp://localhost", (err, connection) => {
     if(!err) {
         connection.createChannel((err, channel) => {
           if (!err) {
-              channel.assertQueue("myQueue", (err, ok) => {
+              channel.assertQueue("myQueue", {}, (err, ok) => {
                   if(!err) {
                       channel.consume("myQueue", newMsg => console.log("New Message: " + newMsg.content.toString()));
                   }