Skip to content
This repository was archived by the owner on Apr 8, 2024. It is now read-only.

Commit 3a1036a

Browse files
authored
Merge pull request #165 from jwulf/0.23.1
2 parents 772b5c6 + 07c79f4 commit 3a1036a

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "zeebe-node",
3-
"version": "v0.23.0",
3+
"version": "v0.23.1",
44
"description": "A Node.js client library for the Zeebe Microservices Orchestration Engine.",
55
"keywords": [
66
"zeebe",

src/lib/ZBWorkerBase.ts

+3-2
Original file line numberDiff line numberDiff line change
@@ -147,16 +147,17 @@ export class ZBWorkerBase<
147147
options.onConnectionError?.()
148148

149149
if (this.connected) {
150-
this.emit(ConnectionStatusEvent.ConnectionError, onError)
150+
this.emit(ConnectionStatusEvent.ConnectionError)
151151
options.onConnectionError?.()
152152
this.connected = false
153153
this.readied = false
154+
this.stall()
154155
}
155156
}
156157
this.grpcClient.on(ConnectionStatusEvent.ConnectionError, onError)
157158
const onReady = async () => {
158159
if (!this.readied) {
159-
this.emit(ConnectionStatusEvent.Ready, onReady)
160+
this.emit(ConnectionStatusEvent.Ready)
160161
options.onReady?.()
161162
this.readied = true
162163
this.connected = true

0 commit comments

Comments
 (0)