There was something inconsistent with this test in case of Rabbit message bus where the test pre-maturely calls the cleanup method though the waitForDeploy() in deploy(routerDefinition) was still verifying the deployed stream.  That left the queues/topics in the rabbitmq because the test was still executing. Adding an explicit sleep after deploy fixed the issue. I will definitely take a deep look at it later.