Comparing version 0.0.8 to 0.0.9
@@ -195,2 +195,3 @@ 'use strict' | ||
this.channels = {} | ||
this.queue = [] | ||
if (this.client) { | ||
@@ -278,3 +279,5 @@ return this.client.end() | ||
debug('[_insertMessageInQueue] message.retries', message._retries) | ||
this.queue.push(message) | ||
if (this.state !== states.closing) { | ||
this.queue.push(message) | ||
} | ||
} | ||
@@ -281,0 +284,0 @@ |
{ | ||
"name": "pg-notify", | ||
"version": "0.0.8", | ||
"version": "0.0.9", | ||
"description": "Postgres pubsub client", | ||
@@ -9,2 +9,3 @@ "main": "index.js", | ||
"test:types": "tsd", | ||
"test:all": "npm run lint && npm run test && npm run test:types", | ||
"lint": "standard", | ||
@@ -11,0 +12,0 @@ "coverage": "nyc ava --serial" |
13088
295