changed variable name message -> payload

polypheny · Sep 25, 2023 · 5610f8f · 5610f8f
1 parent d24a242
commit 5610f8f
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/plugins/mqtt-stream/build.gradle b/plugins/mqtt-stream/build.gradle
@@ -14,6 +14,7 @@ dependencies {
 
     // https://mvnrepository.com/artifact/com.hivemq/hivemq-mqtt-client
     implementation group: 'com.hivemq', name: 'hivemq-mqtt-client', version: hivemq_mqttclient_version
+    //TODO: remove
     // https://mvnrepository.com/artifact/org.bouncycastle/bcprov-jdk15on
     implementation group: 'org.bouncycastle', name: 'bcprov-jdk15on', version: '1.70'
 

diff --git a/plugins/mqtt-stream/src/main/java/org/polypheny/db/mqtt/MqttMessage.java b/plugins/mqtt-stream/src/main/java/org/polypheny/db/mqtt/MqttMessage.java
@@ -21,15 +21,20 @@
 
 public class MqttMessage implements StreamMessage {
 
-    @Getter
-    final String message;
+
+    final String payload;
     @Getter
     final String topic;
 
 
-    public MqttMessage( String message, String topic ) {
-        this.message = message;
+    public MqttMessage( String payload, String topic ) {
+        this.payload = payload;
         this.topic = topic;
     }
 
+
+    public String getMessage() {
+        return this.payload;
+    }
+
 }