Added active flag to Subscription

2012-09-01 11:41:57 +02:00
parent 5644b8e048
commit 4ef628d0e6
1 changed files with 9 additions and 0 deletions
@@ -16,6 +16,7 @@ public class Subscription implements Serializable {
    String clientId;
    String topic;
    boolean cleanSession;
+    boolean active = true;
    
    public Subscription(String clientId, String topic, QOSType requestedQos, boolean cleanSession) {
        this.requestedQos = requestedQos;
@@ -40,6 +41,14 @@ public class Subscription implements Serializable {
        return this.cleanSession;
    }

+    public boolean isActive() {
+        return active;
+    }
+
+    public void setActive(boolean active) {
+        this.active = active;
+    }
+
    @Override
    public boolean equals(Object obj) {
        if (obj == null) {