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()));
                   }