Merge pull request #28 from CSU-ITC303-ITC309-2023-Team8/feature/mqtt…

…_front_end_processors MQTT Processors Fixes UAT Round 1
DPIclimate · Oct 8, 2023 · 8170b8b · 8170b8b
2 parents a193610 + bff404a
commit 8170b8b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/doc/mqtt_processor_plugins.md b/doc/mqtt_processor_plugins.md
@@ -18,7 +18,7 @@ The `on_message` function will be passed the following parameters.
 | Parameter name | Type | Description |
 |:---:|:---:|:---:|
 | message | <kbd>string</kbd> | The MQTT message received as a string. |
-| properties | <kbd>dictionary</kbd> | An dictionary containing the original pikamq callback parameters. `channel`, `method`, `properties`, `body` |
+| properties | <kbd>dictionary</kbd> | A dictionary containing the following pikamq callback parameters. `channel`, `method`, `properties` |
 
 ### `on_message` return
 

diff --git a/src/python/mqtt_processors/MQTTProcessors.py b/src/python/mqtt_processors/MQTTProcessors.py
@@ -122,7 +122,7 @@ def on_message(channel, method, properties, body, plugin_name):
         std_logger.info(f"{channel}")
         std_logger.info(f"Message Received for {plugin_name}")
         messages_received.inc()
-        processed_message = plugin_modules[plugin_name].on_message(body, { 'channel': channel, 'method': method, 'properties': properties, 'body': body })
+        processed_message = plugin_modules[plugin_name].on_message(body, { 'channel': channel, 'method': method, 'properties': properties })
 
         # Publish Messages to Physical Timeseries
         for message in processed_message['messages']: