bus.bindPubSubConsumer("topic:z", consumer, null);
testChannel.send(MessageBuilder.withPayload("y").build());
Thread.sleep(2000);
testChannel.send(MessageBuilder.withPayload("z").build());
Thread.sleep(2000);
assertEquals("y", consumer.receive(2000).getPayload());
assertEquals("z", consumer.receive(2000).getPayload());
assertEquals(0, consumer.getQueueSize());
verifyDynamicProperties(bus, "topic");