diff --git a/gateleen-cache/pom.xml b/gateleen-cache/pom.xml
index ec1ab879e..e3e9e8b65 100644
--- a/gateleen-cache/pom.xml
+++ b/gateleen-cache/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-cache</artifactId>
diff --git a/gateleen-core/pom.xml b/gateleen-core/pom.xml
index 7ca3e99ee..d3c5f099c 100644
--- a/gateleen-core/pom.xml
+++ b/gateleen-core/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-core</artifactId>
diff --git a/gateleen-delegate/pom.xml b/gateleen-delegate/pom.xml
index 76f734231..763efe1a9 100644
--- a/gateleen-delegate/pom.xml
+++ b/gateleen-delegate/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-delegate</artifactId>
diff --git a/gateleen-delta/pom.xml b/gateleen-delta/pom.xml
index 707c2b705..183116226 100644
--- a/gateleen-delta/pom.xml
+++ b/gateleen-delta/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-delta</artifactId>
diff --git a/gateleen-delta/src/main/java/org/swisspush/gateleen/delta/DeltaHandler.java b/gateleen-delta/src/main/java/org/swisspush/gateleen/delta/DeltaHandler.java
index fa37b8cb2..3cff33d97 100755
--- a/gateleen-delta/src/main/java/org/swisspush/gateleen/delta/DeltaHandler.java
+++ b/gateleen-delta/src/main/java/org/swisspush/gateleen/delta/DeltaHandler.java
@@ -6,6 +6,8 @@
 import io.vertx.core.AsyncResult;
 import io.vertx.core.Handler;
 import io.vertx.core.MultiMap;
+import io.vertx.core.Vertx;
+import io.vertx.core.buffer.Buffer;
 import io.vertx.core.http.*;
 import io.vertx.core.json.JsonArray;
 import io.vertx.core.json.JsonObject;
@@ -17,6 +19,9 @@
 import org.swisspush.gateleen.core.util.*;
 import org.swisspush.gateleen.core.util.ExpansionDeltaUtil.CollectionResourceContainer;
 import org.swisspush.gateleen.core.util.ExpansionDeltaUtil.SlashHandling;
+import org.swisspush.gateleen.logging.LogAppenderRepository;
+import org.swisspush.gateleen.logging.LoggingHandler;
+import org.swisspush.gateleen.logging.LoggingResourceManager;
 import org.swisspush.gateleen.routing.Router;
 import org.swisspush.gateleen.routing.Rule;
 import org.swisspush.gateleen.routing.RuleFeaturesProvider;
@@ -24,6 +29,7 @@
 
 import java.util.*;
 
+import static org.swisspush.gateleen.logging.LoggingHandler.SKIP_LOGGING_HEADER;
 import static org.swisspush.gateleen.routing.RuleFeatures.Feature.DELTA_ON_BACKEND;
 
 /**
@@ -54,18 +60,28 @@ public class DeltaHandler implements RuleProvider.RuleChangesObserver {
     private boolean rejectLimitOffsetRequests;
 
     private RuleProvider ruleProvider;
+
+    private final Vertx vertx;
+    private final LoggingResourceManager loggingResourceManager;
+    private final LogAppenderRepository logAppenderRepository;
     private RuleFeaturesProvider ruleFeaturesProvider = new RuleFeaturesProvider(new ArrayList<>());
 
-    public DeltaHandler(RedisProvider redisProvider, HttpClient httpClient, RuleProvider ruleProvider) {
-        this(redisProvider, httpClient, ruleProvider, false);
+    public DeltaHandler(Vertx vertx, RedisProvider redisProvider, HttpClient httpClient, RuleProvider ruleProvider,
+                        LoggingResourceManager loggingResourceManager, LogAppenderRepository logAppenderRepository) {
+        this(vertx,redisProvider, httpClient, ruleProvider, loggingResourceManager, logAppenderRepository, false);
     }
 
-    public DeltaHandler(RedisProvider redisProvider, HttpClient httpClient, RuleProvider ruleProvider, boolean rejectLimitOffsetRequests) {
+    public DeltaHandler(Vertx vertx, RedisProvider redisProvider, HttpClient httpClient, RuleProvider ruleProvider,
+                        LoggingResourceManager loggingResourceManager, LogAppenderRepository logAppenderRepository,
+                        boolean rejectLimitOffsetRequests) {
+        this.vertx = vertx;
         this.redisProvider = redisProvider;
         this.httpClient = httpClient;
         this.rejectLimitOffsetRequests = rejectLimitOffsetRequests;
 
         this.ruleProvider = ruleProvider;
+        this.loggingResourceManager = loggingResourceManager;
+        this.logAppenderRepository = logAppenderRepository;
         this.ruleProvider.registerObserver(this);
     }
 
@@ -284,6 +300,9 @@ private DeltaResourcesContainer getDeltaResourceNames(List<String> subResourceNa
     private void handleCollectionGET(final HttpServerRequest request, final String updateId, final Logger log) {
         request.pause();
 
+        final LoggingHandler loggingHandler = new LoggingHandler(loggingResourceManager, logAppenderRepository, request, vertx.eventBus());
+        loggingHandler.request(request.headers());
+
         final HttpMethod method = HttpMethod.GET;
         final String targetUri = ExpansionDeltaUtil.constructRequestUri(request.path(), request.params(), null, null, SlashHandling.KEEP);
         log.debug("constructed uri for request: {}", targetUri);
@@ -299,6 +318,7 @@ private void handleCollectionGET(final HttpServerRequest request, final String u
             cReq.headers().setAll(request.headers());
             // add a marker header to signalize, that in the next loop of the mainverticle we should pass the deltahandler
             cReq.headers().set(DELTA_BACKEND_HEADER, "");
+            cReq.headers().set(SKIP_LOGGING_HEADER, "true");
             cReq.headers().set("Accept", "application/json");
             cReq.setChunked(true);
             request.handler(cReq::write);
@@ -307,6 +327,8 @@ private void handleCollectionGET(final HttpServerRequest request, final String u
                     HttpClientResponse cRes = asyncResult1.result();
                     HttpServerRequestUtil.prepareResponse(request, cRes);
 
+                    loggingHandler.setResponse(cRes);
+
                     if (cRes.headers().contains(DELTA_HEADER)) {
                         cRes.handler(data -> request.response().write(data));
                         cRes.endHandler(v1 -> request.response().end());
@@ -327,7 +349,7 @@ private void handleCollectionGET(final HttpServerRequest request, final String u
                                     log.trace("DeltaHandler: deltaResourceKeys for targetUri ({}): {}", targetUri, deltaResourceKeys);
                                 }
 
-                                if (deltaResourceKeys.size() > 0) {
+                                if (!deltaResourceKeys.isEmpty()) {
                                     if (log.isTraceEnabled()) {
                                         log.trace("DeltaHandler: targetUri ({}) using mget command.", targetUri);
                                     }
@@ -345,9 +367,12 @@ private void handleCollectionGET(final HttpServerRequest request, final String u
 
                                         JsonObject result = buildResultJsonObject(deltaResourcesContainer.getResourceNames(),
                                                 dataContainer.getCollectionName());
+                                        String responseBody = result.toString();
                                         request.response().putHeader(DELTA_HEADER,
                                                 "" + deltaResourcesContainer.getMaxUpdateId());
-                                        request.response().end(result.toString());
+                                        loggingHandler.appendResponsePayload(Buffer.buffer(responseBody));
+                                        loggingHandler.log();
+                                        request.response().end(responseBody);
                                     })).onFailure(event -> {
                                         log.error("Redis: handleCollectionGET failed", event);
                                         handleError(request, "error reading delta information");
diff --git a/gateleen-delta/src/test/java/org/swisspush/gateleen/delta/DeltaHandlerTest.java b/gateleen-delta/src/test/java/org/swisspush/gateleen/delta/DeltaHandlerTest.java
index d9cdddfd4..ef9546296 100644
--- a/gateleen-delta/src/test/java/org/swisspush/gateleen/delta/DeltaHandlerTest.java
+++ b/gateleen-delta/src/test/java/org/swisspush/gateleen/delta/DeltaHandlerTest.java
@@ -1,9 +1,6 @@
 package org.swisspush.gateleen.delta;
 
-import io.vertx.core.AsyncResult;
-import io.vertx.core.Future;
-import io.vertx.core.Handler;
-import io.vertx.core.MultiMap;
+import io.vertx.core.*;
 import io.vertx.core.http.HttpMethod;
 import io.vertx.core.http.HttpServerRequest;
 import io.vertx.core.http.HttpServerResponse;
@@ -19,6 +16,8 @@
 import org.swisspush.gateleen.core.http.DummyHttpServerResponse;
 import org.swisspush.gateleen.core.redis.RedisProvider;
 import org.swisspush.gateleen.core.util.StatusCode;
+import org.swisspush.gateleen.logging.LogAppenderRepository;
+import org.swisspush.gateleen.logging.LoggingResourceManager;
 import org.swisspush.gateleen.routing.Router;
 import org.swisspush.gateleen.routing.Rule;
 import org.swisspush.gateleen.routing.RuleProvider;
@@ -36,6 +35,9 @@ public class DeltaHandlerTest {
     private RedisAPI redisAPI;
     private RedisProvider redisProvider;
     private RuleProvider ruleProvider;
+    private Vertx vertx;
+    private LoggingResourceManager loggingResourceManager;
+    private LogAppenderRepository logAppenderRepository;
     private Router router = mock(Router.class);
     private HttpServerRequest request;
     private HttpServerResponse response;
@@ -44,6 +46,9 @@ public class DeltaHandlerTest {
     @Before
     public void before() {
         redisAPI = mock(RedisAPI.class);
+        vertx = mock(Vertx.class);
+        loggingResourceManager = mock(LoggingResourceManager.class);
+        logAppenderRepository = mock(LogAppenderRepository.class);
 
         redisProvider = mock(RedisProvider.class);
         when(redisProvider.redis()).thenReturn(Future.succeededFuture(redisAPI));
@@ -69,7 +74,7 @@ public void before() {
 
     @Test
     public void testIsDeltaRequest(TestContext context) {
-        DeltaHandler deltaHandler = new DeltaHandler(redisProvider, null, ruleProvider);
+        DeltaHandler deltaHandler = new DeltaHandler(vertx, redisProvider, null, ruleProvider, loggingResourceManager, logAppenderRepository);
         deltaHandler.rulesChanged(List.of(
                 rule("/gateleen/server/res_1", false),
                 rule("/gateleen/server/res_2", true))
@@ -152,7 +157,7 @@ public void testIsDeltaRequest(TestContext context) {
 
     @Test
     public void testDeltaNoExpiry() {
-        DeltaHandler deltaHandler = new DeltaHandler(redisProvider, null, ruleProvider);
+        DeltaHandler deltaHandler = new DeltaHandler(vertx, redisProvider, null, ruleProvider, loggingResourceManager, logAppenderRepository);
         deltaHandler.handle(request, router);
 
         verify(redisAPI, times(1)).set(eq(Arrays.asList("delta:resources:a:b:c", "555")), any());
@@ -163,7 +168,7 @@ public void testDeltaNoExpiry() {
     public void testDeltaWithExpiry() {
         requestHeaders.add("x-expire-after", "123");
 
-        DeltaHandler deltaHandler = new DeltaHandler(redisProvider, null, ruleProvider);
+        DeltaHandler deltaHandler = new DeltaHandler(vertx, redisProvider, null, ruleProvider, loggingResourceManager, logAppenderRepository);
         deltaHandler.handle(request, router);
 
         verify(redisAPI, times(1)).setex(eq("delta:resources:a:b:c"), eq("123"), eq("555"), any());
@@ -182,7 +187,7 @@ public void testFailingRedisProviderAccess(TestContext context) {
         ArgumentCaptor<String> bodyCaptor = ArgumentCaptor.forClass(String.class);
         when(request.response().end(bodyCaptor.capture())).thenReturn(Future.succeededFuture());
 
-        DeltaHandler deltaHandler = new DeltaHandler(redisProvider, null, ruleProvider);
+        DeltaHandler deltaHandler = new DeltaHandler(vertx, redisProvider, null, ruleProvider, loggingResourceManager, logAppenderRepository);
         deltaHandler.handle(request, router);
 
         context.assertEquals(StatusCode.INTERNAL_SERVER_ERROR.getStatusCode(), statusCodeCaptor.getValue(), "StatusCode should be 500");
@@ -191,7 +196,7 @@ public void testFailingRedisProviderAccess(TestContext context) {
 
     @Test
     public void testRejectLimitOffsetParameters(TestContext context) {
-        DeltaHandler deltaHandler = new DeltaHandler(redisProvider, null, ruleProvider, true);
+        DeltaHandler deltaHandler = new DeltaHandler(vertx, redisProvider, null, ruleProvider, loggingResourceManager, logAppenderRepository, true);
         final DummyHttpServerResponse response = new DummyHttpServerResponse();
         DeltaRequest request = new DeltaRequest(MultiMap.caseInsensitiveMultiMap()
                 .add("delta", "0")
diff --git a/gateleen-expansion/pom.xml b/gateleen-expansion/pom.xml
index 6fd869f93..eccef3a97 100644
--- a/gateleen-expansion/pom.xml
+++ b/gateleen-expansion/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-expansion</artifactId>
diff --git a/gateleen-hook-js/pom.xml b/gateleen-hook-js/pom.xml
index 6790dd29b..23ee18dad 100644
--- a/gateleen-hook-js/pom.xml
+++ b/gateleen-hook-js/pom.xml
@@ -4,7 +4,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
     <artifactId>gateleen-hook-js</artifactId>
     <packaging>jar</packaging>
diff --git a/gateleen-hook/pom.xml b/gateleen-hook/pom.xml
index 957613927..31db87a57 100644
--- a/gateleen-hook/pom.xml
+++ b/gateleen-hook/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-hook</artifactId>
diff --git a/gateleen-kafka/pom.xml b/gateleen-kafka/pom.xml
index ab53b09fe..3d40b8495 100644
--- a/gateleen-kafka/pom.xml
+++ b/gateleen-kafka/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-kafka</artifactId>
diff --git a/gateleen-logging/pom.xml b/gateleen-logging/pom.xml
index 446f61684..90e852078 100644
--- a/gateleen-logging/pom.xml
+++ b/gateleen-logging/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-logging</artifactId>
diff --git a/gateleen-logging/src/main/java/org/swisspush/gateleen/logging/LoggingHandler.java b/gateleen-logging/src/main/java/org/swisspush/gateleen/logging/LoggingHandler.java
index dfe9e3204..094d9322d 100755
--- a/gateleen-logging/src/main/java/org/swisspush/gateleen/logging/LoggingHandler.java
+++ b/gateleen-logging/src/main/java/org/swisspush/gateleen/logging/LoggingHandler.java
@@ -64,6 +64,8 @@ public class LoggingHandler {
     private static final String ADDRESS = "address";
     private static final String DEFAULT = "default";
 
+    public static final String SKIP_LOGGING_HEADER = "x-skip-request-log";
+
     private Map<String, org.apache.logging.log4j.Logger> loggers = new HashMap<>();
 
     private Logger log;
@@ -76,6 +78,12 @@ public LoggingHandler(LoggingResourceManager loggingResourceManager, LogAppender
         this.log = RequestLoggerFactory.getLogger(LoggingHandler.class, request);
         ((org.apache.logging.log4j.core.Logger) LogManager.getLogger(DEFAULT_LOGGER)).setAdditive(false);
         boolean stopValidation = false;
+
+        if(request.headers().get(SKIP_LOGGING_HEADER) != null) {
+            log.info("request will not be logged because of skip log request header");
+            return;
+        }
+
         for (Map<String, String> payloadFilter : loggingResource.getPayloadFilters()) {
             if (active || stopValidation) {
                 break;
diff --git a/gateleen-merge/pom.xml b/gateleen-merge/pom.xml
index a33161ac6..8a22df2c1 100644
--- a/gateleen-merge/pom.xml
+++ b/gateleen-merge/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-merge</artifactId>
diff --git a/gateleen-monitoring/pom.xml b/gateleen-monitoring/pom.xml
index 4242c1777..2ab2ec3c5 100644
--- a/gateleen-monitoring/pom.xml
+++ b/gateleen-monitoring/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-monitoring</artifactId>
diff --git a/gateleen-packing/pom.xml b/gateleen-packing/pom.xml
index 00d804238..355eb53a2 100644
--- a/gateleen-packing/pom.xml
+++ b/gateleen-packing/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-packing</artifactId>
diff --git a/gateleen-player/pom.xml b/gateleen-player/pom.xml
index 32e1414f7..8b242ea71 100644
--- a/gateleen-player/pom.xml
+++ b/gateleen-player/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-player</artifactId>
diff --git a/gateleen-playground/pom.xml b/gateleen-playground/pom.xml
index 50e9ac122..fba9fb3d4 100644
--- a/gateleen-playground/pom.xml
+++ b/gateleen-playground/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-playground</artifactId>
diff --git a/gateleen-playground/src/main/java/org/swisspush/gateleen/playground/Server.java b/gateleen-playground/src/main/java/org/swisspush/gateleen/playground/Server.java
index 4958f46f1..2559fd4cc 100755
--- a/gateleen-playground/src/main/java/org/swisspush/gateleen/playground/Server.java
+++ b/gateleen-playground/src/main/java/org/swisspush/gateleen/playground/Server.java
@@ -215,7 +215,8 @@ public void start() {
 
                 RuleProvider ruleProvider = new RuleProvider(vertx, RULES_ROOT, storage, props);
 
-                deltaHandler = new DeltaHandler(redisProvider, selfClient, ruleProvider, true);
+                deltaHandler = new DeltaHandler(vertx, redisProvider, selfClient, ruleProvider, loggingResourceManager,
+                        logAppenderRepository, true);
                 expansionHandler = new ExpansionHandler(ruleProvider, selfClient, props, ROOT);
                 copyResourceHandler = new CopyResourceHandler(selfClient, exceptionFactory, SERVER_ROOT + "/v1/copy");
                 monitoringHandler = new MonitoringHandler(vertx, storage, PREFIX, SERVER_ROOT + "/monitoring/rpr");
diff --git a/gateleen-qos/pom.xml b/gateleen-qos/pom.xml
index 8cca1b4c2..0180f8524 100644
--- a/gateleen-qos/pom.xml
+++ b/gateleen-qos/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-qos</artifactId>
diff --git a/gateleen-queue/pom.xml b/gateleen-queue/pom.xml
index 5f42bd0a2..c934c8d06 100644
--- a/gateleen-queue/pom.xml
+++ b/gateleen-queue/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-queue</artifactId>
diff --git a/gateleen-routing/pom.xml b/gateleen-routing/pom.xml
index 85ab49b46..cf4ca24d7 100644
--- a/gateleen-routing/pom.xml
+++ b/gateleen-routing/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-routing</artifactId>
diff --git a/gateleen-runconfig/pom.xml b/gateleen-runconfig/pom.xml
index c6e4daa80..8160d728a 100644
--- a/gateleen-runconfig/pom.xml
+++ b/gateleen-runconfig/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-runconfig</artifactId>
diff --git a/gateleen-scheduler/pom.xml b/gateleen-scheduler/pom.xml
index 25367dc43..8cf791b4f 100644
--- a/gateleen-scheduler/pom.xml
+++ b/gateleen-scheduler/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-scheduler</artifactId>
diff --git a/gateleen-security/pom.xml b/gateleen-security/pom.xml
index 9173fc016..7ad3b2c6f 100644
--- a/gateleen-security/pom.xml
+++ b/gateleen-security/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-security</artifactId>
diff --git a/gateleen-test/pom.xml b/gateleen-test/pom.xml
index 79bc6c1a2..e2d983266 100644
--- a/gateleen-test/pom.xml
+++ b/gateleen-test/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
     <artifactId>gateleen-test</artifactId>
     <packaging>jar</packaging>
diff --git a/gateleen-test/src/test/java/org/swisspush/gateleen/AbstractTest.java b/gateleen-test/src/test/java/org/swisspush/gateleen/AbstractTest.java
index c12381d80..20f2480b4 100755
--- a/gateleen-test/src/test/java/org/swisspush/gateleen/AbstractTest.java
+++ b/gateleen-test/src/test/java/org/swisspush/gateleen/AbstractTest.java
@@ -247,7 +247,7 @@ public static void setupBeforeClass(TestContext context) {
                         RunConfig.with()
                                 .cacheHandler(cacheHandler)
                                 .corsHandler(new CORSHandler())
-                                .deltaHandler(new DeltaHandler(redisProvider, selfClient, ruleProvider))
+                                .deltaHandler(new DeltaHandler(vertx, redisProvider, selfClient, ruleProvider, loggingResourceManager, logAppenderRepository))
                                 .expansionHandler(new ExpansionHandler(vertx, storage, selfClient, props, ROOT, RULES_ROOT))
                                 .hookHandler(hookHandler)
                                 .qosHandler(qosHandler)
diff --git a/gateleen-test/src/test/java/org/swisspush/gateleen/hook/ListenerTest.java b/gateleen-test/src/test/java/org/swisspush/gateleen/hook/ListenerTest.java
index 4a858aab5..4282fe13e 100755
--- a/gateleen-test/src/test/java/org/swisspush/gateleen/hook/ListenerTest.java
+++ b/gateleen-test/src/test/java/org/swisspush/gateleen/hook/ListenerTest.java
@@ -3,7 +3,6 @@
 import com.github.tomakehurst.wiremock.client.WireMock;
 import com.github.tomakehurst.wiremock.junit.WireMockRule;
 import com.google.common.collect.ImmutableMap;
-import org.awaitility.Awaitility;
 import io.restassured.RestAssured;
 import io.restassured.http.Header;
 import io.restassured.http.Headers;
@@ -11,7 +10,7 @@
 import io.vertx.ext.unit.Async;
 import io.vertx.ext.unit.TestContext;
 import io.vertx.ext.unit.junit.VertxUnitRunner;
-import org.junit.Ignore;
+import org.awaitility.Awaitility;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -24,8 +23,8 @@
 
 import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
 import static com.github.tomakehurst.wiremock.stubbing.Scenario.STARTED;
-import static org.awaitility.Awaitility.await;
 import static io.restassured.RestAssured.*;
+import static org.awaitility.Awaitility.await;
 import static org.awaitility.Durations.FIVE_SECONDS;
 import static org.awaitility.Durations.TEN_SECONDS;
 import static org.hamcrest.CoreMatchers.*;
diff --git a/gateleen-test/src/test/java/org/swisspush/gateleen/queue/QueueTest.java b/gateleen-test/src/test/java/org/swisspush/gateleen/queue/QueueTest.java
index 6113621be..cecb34778 100644
--- a/gateleen-test/src/test/java/org/swisspush/gateleen/queue/QueueTest.java
+++ b/gateleen-test/src/test/java/org/swisspush/gateleen/queue/QueueTest.java
@@ -14,8 +14,8 @@
 
 import static org.awaitility.Awaitility.await;
 import static io.restassured.RestAssured.*;
-import static junit.framework.Assert.assertFalse;
-import static junit.framework.Assert.assertTrue;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
 import static org.awaitility.Durations.*;
 import static org.hamcrest.CoreMatchers.*;
 
diff --git a/gateleen-testhelper/pom.xml b/gateleen-testhelper/pom.xml
index ec439ba52..be1133191 100644
--- a/gateleen-testhelper/pom.xml
+++ b/gateleen-testhelper/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-testhelper</artifactId>
diff --git a/gateleen-user/pom.xml b/gateleen-user/pom.xml
index 92cc2d300..5624e3d66 100644
--- a/gateleen-user/pom.xml
+++ b/gateleen-user/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-user</artifactId>
diff --git a/gateleen-validation/pom.xml b/gateleen-validation/pom.xml
index 5afcddce0..772ef9759 100644
--- a/gateleen-validation/pom.xml
+++ b/gateleen-validation/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.swisspush.gateleen</groupId>
         <artifactId>gateleen</artifactId>
-        <version>2.1.8-SNAPSHOT</version>
+        <version>2.1.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>gateleen-validation</artifactId>
diff --git a/pom.xml b/pom.xml
index 19ae1663a..3d22cf63b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>org.swisspush.gateleen</groupId>
     <artifactId>gateleen</artifactId>
-    <version>2.1.8-SNAPSHOT</version>
+    <version>2.1.9-SNAPSHOT</version>
     <packaging>pom</packaging>
     <name>gateleen</name>
     <description>Middleware library based on Vert.x to build advanced JSON/REST communication servers</description>