From 4ef628d0e66e86bc8ea862b9af14243957ca9427 Mon Sep 17 00:00:00 2001
From: "selva.andre" <selva.andre@gmail.com>
Date: Sat, 1 Sep 2012 11:41:57 +0200
Subject: [PATCH] Added active flag to Subscription

---
 .../mqtt/moquette/messaging/spi/impl/Subscription.java   | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/Subscription.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/Subscription.java
index 59f431ac..b065985c 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/Subscription.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/Subscription.java
@@ -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) {