Fix for #77

cepheus-cep/src/main/java/com/orange/cepheus/cep/SubscriptionManager.java

@@ -258,6 +258,22 @@ private void subscribeProvider(Provider provider, SubscribeContext subscribeCont
             logger.warn("Error during subscription for {}", provider.getUrl(), throwable);
         });
     }
+
+    /**
+     * Unsubscribe from Provider of the configuration that is being deleted
+     * @param configuration the configuration that is being deleted
+     */
+    public void unsubscribe(Configuration configuration){
+    	List<EventTypeIn> eventTypeIns = Collections.emptyList();
+        eventTypeIns = configuration.getEventTypeIns();
+        for (EventTypeIn eventType : eventTypeIns) {
+            for (Provider provider : eventType.getProviders()) {
+	        if (provider != null) {
+		    unsubscribeProvider(provider);
+		}
+            }
+	}
+    }
 
     /**
      * Unsubscribe from a provider

cepheus-cep/src/main/java/com/orange/cepheus/cep/controller/AdminController.java

@@ -144,6 +144,12 @@ public synchronized ResponseEntity<Configuration> removeConfiguration() throws P
         if (tenantFilter != null) {
             tenantFilter.removeTenant(configurationId);
         }
+	// Retrieve the configuration
+        final Configuration configuration = complexEventProcessor.getConfiguration();
+        // Unsubscribe from Provider of the configuration
+	if (configuration != null) {
+	    subscriptionManager.unsubscribe(configuration);
+        }
         // Reset the CEP
         complexEventProcessor.reset();
         // Delete the persisted configuration