File tree Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Original file line number Diff line number Diff line change 63
63
the connection is invalid and attempts to reconnect.
64
64
Default is 3000ms (3 seconds). This duration must be shorter than `keep_alive_secs`.
65
65
66
+ **protocol_operation_timeout_ms** (`int`): Milliseconds to wait for the response to the operation
67
+ requires response by protocol. Set to zero to disable timeout. Otherwise,
68
+ the operation will fail if no response is received within this amount of time after
69
+ the packet is written to the socket
70
+ It applied to PUBLISH (QoS>0) and UNSUBSCRIBE now.
71
+
66
72
**will** (:class:`awscrt.mqtt.Will`): Will to send with CONNECT packet. The will is
67
73
published by the server when its connection to the client is unexpectedly lost.
68
74
@@ -180,6 +186,7 @@ def _builder(
180
186
reconnect_max_timeout_secs = kwargs .get ('reconnect_max_timeout_secs' , 60 ),
181
187
keep_alive_secs = kwargs .get ('keep_alive_secs' , 1200 ),
182
188
ping_timeout_ms = kwargs .get ('ping_timeout_ms' , 3000 ),
189
+ protocol_operation_timeout_ms = kwargs .get ('protocol_operation_timeout_ms' , 0 ),
183
190
will = kwargs .get ('will' ),
184
191
username = username ,
185
192
password = kwargs .get ('password' ),
Original file line number Diff line number Diff line change 19
19
"Operating System :: OS Independent" ,
20
20
],
21
21
install_requires = [
22
- 'awscrt==0.10.8 ' ,
22
+ 'awscrt==0.11.4 ' ,
23
23
],
24
24
python_requires = '>=3.5' ,
25
25
)
You can’t perform that action at this time.
0 commit comments