diff --git a/doc/mqtt_processor_plugins.md b/doc/mqtt_processor_plugins.md
index 19288f2f..7c4592e8 100644
--- 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
index dadb7a17..e51ea862 100644
--- 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']: