diff options
| author | PradeepKiruvale <PRADEEPKIRUVALE@gmail.com> | 2021-09-28 17:44:32 +0530 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-09-28 17:44:32 +0530 |
| commit | 21983abda75db5a8099e3ad4005e12365764b2d9 (patch) | |
| tree | 0844a91d5471652a579c8debf78078aa965cd23f /tedge | |
| parent | db6d0f7864e2e2c0b08f73855afd5a5d8b1cb27e (diff) | |
Increase the max packet size (#450)
Co-authored-by: Pradeep Kumar K J <pradeepkumar.kj@sofwareag.com>
Diffstat (limited to 'tedge')
| -rw-r--r-- | tedge/src/cli/mqtt/subscribe.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/tedge/src/cli/mqtt/subscribe.rs b/tedge/src/cli/mqtt/subscribe.rs index 8b7abe88..f60e5ef9 100644 --- a/tedge/src/cli/mqtt/subscribe.rs +++ b/tedge/src/cli/mqtt/subscribe.rs @@ -4,6 +4,7 @@ use rumqttc::QoS; use rumqttc::{Client, Event, Incoming, MqttOptions, Packet}; const DEFAULT_QUEUE_CAPACITY: usize = 10; +const MAX_PACKET_SIZE: usize = 1048575; pub struct MqttSubscribeCommand { pub host: String, @@ -30,6 +31,7 @@ impl Command for MqttSubscribeCommand { fn subscribe(cmd: &MqttSubscribeCommand) -> Result<(), MqttError> { let mut options = MqttOptions::new(cmd.client_id.as_str(), &cmd.host, cmd.port); options.set_clean_session(true); + options.set_max_packet_size(MAX_PACKET_SIZE, MAX_PACKET_SIZE); let (mut client, mut connection) = Client::new(options, DEFAULT_QUEUE_CAPACITY); |