Added a clean session flag support

aperepel · Jan 22, 2016 · 73e3e1d · 73e3e1d
1 parent 02cd254
commit 73e3e1d
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/MqttNiFiConstants.java b/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/MqttNiFiConstants.java
@@ -0,0 +1,10 @@
+package org.apache.nifi.processors.mqtt;
+
+import org.apache.nifi.components.AllowableValue;
+
+public class MqttNiFiConstants {
+    public static final AllowableValue ALLOWABLE_VALUE_CLEAN_SESSION_TRUE =
+            new AllowableValue("true", "Clean Session", "Fresh start, ignore any outstanding QoS 1 & 2 messages");
+    public static final AllowableValue ALLOWABLE_VALUE_CLEAN_SESSION_FALSE =
+            new AllowableValue("false", "Resume Session", "Pick up a previous session state - works in conjunction with a ClientID");
+}