diff --git a/gateleen-test/src/test/java/org/swisspush/gateleen/queue/expiry/ResourceQueueExpiryTest.java b/gateleen-test/src/test/java/org/swisspush/gateleen/queue/expiry/ResourceQueueExpiryTest.java index 06f3c173..37d60538 100644 --- a/gateleen-test/src/test/java/org/swisspush/gateleen/queue/expiry/ResourceQueueExpiryTest.java +++ b/gateleen-test/src/test/java/org/swisspush/gateleen/queue/expiry/ResourceQueueExpiryTest.java @@ -1,6 +1,7 @@ package org.swisspush.gateleen.queue.expiry; import io.restassured.RestAssured; +import io.vertx.core.json.JsonObject; import io.vertx.ext.unit.Async; import io.vertx.ext.unit.TestContext; import io.vertx.ext.unit.junit.VertxUnitRunner; @@ -36,6 +37,14 @@ public void initRestAssured() { RestAssured.requestSpecification.basePath(SERVER_ROOT + "/"); } + private void initRoutingRules() { + // add a routing + JsonObject rules = new JsonObject(); + rules = TestUtils.addRoutingRuleMainStorage(rules); + rules = TestUtils.addRoutingRuleQueuing(rules); + TestUtils.putRoutingRules(rules); + } + /** * Checks if the GET request of the * given resource returns the wished body. @@ -55,6 +64,7 @@ private void checkGETBodyWithAwait(final String requestUrl, final String body) { public void testQueueExpiry(TestContext context) { Async async = context.async(); delete(); + initRoutingRules(); System.out.println("testQueueExpiry"); @@ -165,6 +175,7 @@ public void testQueueExpiry(TestContext context) { public void testQueueExpiryOverride_requestIsExpired_beforeRegularExpiryTime(TestContext context) { Async async = context.async(); delete(); + initRoutingRules(); System.out.println("testQueueExpiry"); @@ -213,6 +224,7 @@ public void testQueueExpiryOverride_requestIsExpired_beforeRegularExpiryTime(Tes public void testQueueExpiryOverride_requestIsNotExpired_regularResourceExpiry(TestContext context) { Async async = context.async(); delete(); + initRoutingRules(); System.out.println("testQueueExpiry");