Skip to content

Commit c85b28c

Browse files
Added destroy method
1 parent cf86c0a commit c85b28c

File tree

3 files changed

+24
-3
lines changed

3 files changed

+24
-3
lines changed

src/src/bus.js

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -290,12 +290,19 @@
290290
}
291291
};
292292

293+
var destroy = function() {
294+
producer.destroy();
295+
consumer.destroy();
296+
configuration = null;
297+
};
298+
293299
return {
294300
route: route,
295301
send: send,
296302
publish: publish,
297303
sendRequest: sendRequest,
298-
publishRequest: publishRequest
304+
publishRequest: publishRequest,
305+
destroy: destroy
299306
};
300307
};
301308

src/src/clients/stomp/consumer.js

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,9 +82,16 @@
8282
}
8383
};
8484

85+
var destroy = function() {
86+
client.disconnect(function() {
87+
console.log("Disconnected");
88+
});
89+
};
90+
8591
return {
8692
startConsuming: startConsuming,
87-
consumeMessageType: consumeMessageType
93+
consumeMessageType: consumeMessageType,
94+
destroy: destroy
8895
};
8996
};
9097

src/src/clients/stomp/producer.js

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,9 +84,16 @@
8484
}
8585
};
8686

87+
var destroy = function() {
88+
client.disconnect(function() {
89+
console.log("Disconnected");
90+
});
91+
};
92+
8793
return {
8894
publish: publish,
89-
send: send
95+
send: send,
96+
destroy: destroy
9097
};
9198
};
9299

0 commit comments

Comments
 (0)