Saw this is the logs when colocated test was failing:
WARNING: Receiver closed with error
io.vertx.core.impl.NoStackTraceThrowable: Error{condition=amqp:internal-error, description='AMQ219001: error creating temporary queue, Journal must be in state=LOADED, was $
STOPPED]', info=null}
2017-09-08 13:24:14 ERROR QueueScheduler:145 - Error adding broker
java.util.concurrent.ExecutionException: io.vertx.core.impl.NoStackTraceThrowable: Error{condition=amqp:internal-error, description='AMQ219001: error creating temporary que$
e, Journal must be in state=LOADED, was [STOPPED]', info=null}
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915)
at io.enmasse.queue.scheduler.QueueScheduler.lambda$connectionOpened$7(QueueScheduler.java:119)
at io.enmasse.queue.scheduler.QueueScheduler.lambda$executeBlocking$9(QueueScheduler.java:138)
at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271)
at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
Saw this is the logs when colocated test was failing:
WARNING: Receiver closed with error
io.vertx.core.impl.NoStackTraceThrowable: Error{condition=amqp:internal-error, description='AMQ219001: error creating temporary queue, Journal must be in state=LOADED, was $ STOPPED]', info=null}
2017-09-08 13:24:14 ERROR QueueScheduler:145 - Error adding broker
java.util.concurrent.ExecutionException: io.vertx.core.impl.NoStackTraceThrowable: Error{condition=amqp:internal-error, description='AMQ219001: error creating temporary que$ e, Journal must be in state=LOADED, was [STOPPED]', info=null}
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915)
at io.enmasse.queue.scheduler.QueueScheduler.lambda$connectionOpened$7(QueueScheduler.java:119) at io.enmasse.queue.scheduler.QueueScheduler.lambda$executeBlocking$9(QueueScheduler.java:138)
at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271) at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)