Skip to content

Commit b4b94e8

Browse files
authored
Fix listener mode ending (#13)
* Fix listener mode ending * Bump version
1 parent 96e7bbf commit b4b94e8

File tree

3 files changed

+9
-7
lines changed

3 files changed

+9
-7
lines changed

lib/coreClient.js

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -55,12 +55,15 @@ class CoreClient {
5555
Utils.PrintStatistic(context);
5656
}
5757

58-
context.sender && context.sender.detach();
59-
context.receiver && context.receiver.detach();
60-
context.connection.close();
58+
context && context.sender && context.sender.detach();
59+
context && context.receiver && context.receiver.detach();
60+
context && context.connection.close();
6161

62-
this.server && this.server.close();
63-
process.exit();
62+
if(this.server) {
63+
this.server.close();
64+
return;
65+
}
66+
process.exit(0);
6467
}
6568
}
6669

lib/receiverClient.js

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,6 @@ class Receiver extends CoreClient {
8787
if (((!self.options.processReplyTo) || self.options.recvListen) && self.received === self.expected) {
8888
self.received = 0;
8989
self.cancelTimeout();
90-
self.server && context.delivery.accept();
9190
self.close(context, self.options.closeSleep);
9291
}
9392

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "cli-rhea",
3-
"version": "2.1.6",
3+
"version": "2.1.7",
44
"description": "Client interface built on amqp/rhea lib",
55
"scripts": {
66
"test": "mocha test/*Test.js",

0 commit comments

Comments
 (0)