wassname/DefinitelyTyped
1
0 Fork 0
mirror of https://github.com/wassname/DefinitelyTyped.git synced 2026-10-26 12:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

amqplib: callback-api definition and tests added

Browse Source
This commit is contained in:
abreits committed 2015-10-14 15:09:10 +02:00
1 parent 93bcd768f0
commit 9e7d9453a1
1 file changed
+2 -2
Download Patch File Download Diff File Expand all files Collapse all files
amqplib/amqplib-tests.ts
+2 -2
View File
@@ -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()));
}