diff options
| author | PradeepKiruvale <PRADEEPKIRUVALE@gmail.com> | 2021-07-21 18:29:00 +0530 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-07-21 18:29:00 +0530 |
| commit | db9d027765e263f7539a16d8428532d940fa44ce (patch) | |
| tree | 38e9e832ec2399e1878134cecf0b1b6ebaca548f /configuration | |
| parent | 9a37e5f66ee03d04694013133c4dc87336707135 (diff) | |
[CIT-420] mqtt packet size (#346)
* CIT-420] mqtt reconnection on bigger packets
* cargo fmt
* [CIT-420] Add max_packet_size
* [CIT-420] cap packet size at 256MB
* [CIT-420] Address review comments
* Add integration test
* added timeout
* fix the broken test
* [CIT-420] refactor code
* packet creation function
* Fix error handling
* Fix the error handling
* Fix test
* Add a new config
* update the ports
* format
* remove bridge_max_packet_size
* Rename functions and add comments
Co-authored-by: Pradeep K J <Pradeep K J pradeekumar.kj@softwareag.com>
Diffstat (limited to 'configuration')
| -rw-r--r-- | configuration/rumqttd/rumqttd_5883.conf | 27 | ||||
| -rw-r--r-- | configuration/rumqttd/rumqttd_5884.conf | 27 |
2 files changed, 54 insertions, 0 deletions
diff --git a/configuration/rumqttd/rumqttd_5883.conf b/configuration/rumqttd/rumqttd_5883.conf new file mode 100644 index 00000000..be14abf9 --- /dev/null +++ b/configuration/rumqttd/rumqttd_5883.conf @@ -0,0 +1,27 @@ +# Broker id. Used to identify local node of the replication mesh
+id = 0
+
+# A commitlog read will pull full segment. Make sure that a segment isn't
+# too big as async tcp writes readiness of one connection might affect tail
+# latencies of other connection. Not a problem with preempting runtimes
+[router]
+id = 0
+dir = "/tmp/rumqttd"
+max_segment_size = 10240
+max_segment_count = 10
+max_connections = 10
+
+# Configuration of server and connections that it accepts
+[servers.1]
+listen = "0.0.0.0:5883"
+next_connection_delay_ms = 1
+ [servers.1.connections]
+ connection_timeout_ms = 100
+ max_client_id_len = 256
+ throttle_delay_ms = 0
+ max_payload_size = 268435455
+ max_inflight_count = 200
+ max_inflight_size = 1024
+
+[console]
+listen = "0.0.0.0:3030"
\ No newline at end of file diff --git a/configuration/rumqttd/rumqttd_5884.conf b/configuration/rumqttd/rumqttd_5884.conf new file mode 100644 index 00000000..95f8e6ca --- /dev/null +++ b/configuration/rumqttd/rumqttd_5884.conf @@ -0,0 +1,27 @@ +# Broker id. Used to identify local node of the replication mesh
+id = 0
+
+# A commitlog read will pull full segment. Make sure that a segment isn't
+# too big as async tcp writes readiness of one connection might affect tail
+# latencies of other connection. Not a problem with preempting runtimes
+[router]
+id = 0
+dir = "/tmp/rumqttd"
+max_segment_size = 10240
+max_segment_count = 10
+max_connections = 10
+
+# Configuration of server and connections that it accepts
+[servers.1]
+listen = "0.0.0.0:5884"
+next_connection_delay_ms = 1
+ [servers.1.connections]
+ connection_timeout_ms = 100
+ max_client_id_len = 256
+ throttle_delay_ms = 0
+ max_payload_size = 268435455
+ max_inflight_count = 200
+ max_inflight_size = 1024
+
+[console]
+listen = "0.0.0.0:3030"
\ No newline at end of file |