Skip to content

Topic aliasing options to mqtt5 client builder #532

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Nov 22, 2023
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions awsiot/mqtt5_client_builder.py
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,9 @@
handled while the client is not connected. In particular, if the client is not connected, then any operation
that would be failed on disconnect (according to these rules) will also be rejected.

**topic_aliasing_options** (:class:`awscrt.mqtt5.TopicAliasingOptions`): Configuration options for how the client
should use the topic aliasing features of MQTT5

**retry_jitter_mode** (:class:`awscrt.mqtt5.ExponentialBackoffJitterMode`): How the reconnect delay is modified
in order to smooth out the distribution of reconnection attempt timepoints for a large set of reconnecting
clients.
Expand Down Expand Up @@ -288,6 +291,8 @@ def _builder(
client_options.ack_timeout_sec = _get(kwargs, 'ack_timeout_sec')
if client_options.websocket_handshake_transform is None:
client_options.websocket_handshake_transform = websocket_handshake_transform
if client_options.topic_aliasing_options is None:
client_options.topic_aliasing_options = _get(kwargs, 'topic_aliasing_options')

# Connect Options
if client_options.connect_options.client_id is None:
Expand Down
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ def _load_version():
"Operating System :: OS Independent",
],
install_requires=[
'awscrt==0.19.6',
'awscrt==0.19.14',
],
python_requires='>=3.7',
)