File tree 2 files changed +8
-3
lines changed
2 files changed +8
-3
lines changed Original file line number Diff line number Diff line change 1
- 0.4.2
1
+ 0.4.3
Original file line number Diff line number Diff line change @@ -4,13 +4,18 @@ import { pack, unpack } from 'msgpackr'
4
4
5
5
class Messaging {
6
6
constructor ( ) {
7
- this . subTimeoutTime = 600000
8
- this . responseTimeoutTime = Number (
7
+ const timeout = Number (
9
8
process . env . BOPTEST_MESSAGE_TIMEOUT
10
9
? process . env . BOPTEST_MESSAGE_TIMEOUT
11
10
: "1200000" , // Default 20 minute message timeout
12
11
) ;
13
12
13
+ // This is how long we wait for a response from the worker
14
+ this . responseTimeoutTime = timeout
15
+ // This is how long we keep the subscription for a particular test open
16
+ // Subscriptions timeout 1 minutes after the message timeout
17
+ // New API requests to an existing subscription, will refresh the subscription's timeout
18
+ this . subTimeoutTime = timeout + 60000
14
19
this . subscriptionTimers = { }
15
20
this . messageHandlers = { }
16
21
You can’t perform that action at this time.
0 commit comments