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) {