diff --git a/package.json b/package.json index 3d4e5117edb..7ca6c0ef146 100644 --- a/package.json +++ b/package.json @@ -1,7 +1,7 @@ { "name": "teraslice-workspace", "displayName": "Teraslice", - "version": "0.87.0", + "version": "0.87.1", "private": true, "homepage": "https://github.com/terascope/teraslice", "bugs": { diff --git a/packages/teraslice-messaging/package.json b/packages/teraslice-messaging/package.json index 671e7bf77c0..9e87820750a 100644 --- a/packages/teraslice-messaging/package.json +++ b/packages/teraslice-messaging/package.json @@ -1,7 +1,7 @@ { "name": "@terascope/teraslice-messaging", "displayName": "Teraslice Messaging", - "version": "0.34.0", + "version": "0.34.1", "description": "An internal teraslice messaging library using socket.io", "homepage": "https://github.com/terascope/teraslice/tree/master/packages/teraslice-messaging#readme", "bugs": { diff --git a/packages/teraslice-messaging/src/messenger/client.ts b/packages/teraslice-messaging/src/messenger/client.ts index a22d47a2f58..7ef4697938b 100644 --- a/packages/teraslice-messaging/src/messenger/client.ts +++ b/packages/teraslice-messaging/src/messenger/client.ts @@ -122,6 +122,7 @@ export class Client extends Core { this.socket.on('reconnect', () => { this.logger.info(`client ${this.clientId} reconnected`); + this.serverShutdown = false; this.ready = true; this.emit('ready'); diff --git a/packages/teraslice/package.json b/packages/teraslice/package.json index 34edfceca0d..5e15453d334 100644 --- a/packages/teraslice/package.json +++ b/packages/teraslice/package.json @@ -1,7 +1,7 @@ { "name": "teraslice", "displayName": "Teraslice", - "version": "0.87.0", + "version": "0.87.1", "description": "Distributed computing platform for processing JSON data", "homepage": "https://github.com/terascope/teraslice#readme", "bugs": { @@ -43,7 +43,7 @@ "dependencies": { "@terascope/elasticsearch-api": "^3.11.0", "@terascope/job-components": "^0.64.0", - "@terascope/teraslice-messaging": "^0.34.0", + "@terascope/teraslice-messaging": "^0.34.1", "@terascope/utils": "^0.51.0", "async-mutex": "^0.4.0", "barbe": "^3.0.16",