String content = message.getContentAsString();
outbound.add(content);
outboundLatch.countDown();
}
});
ClientSubscription subscription = builder.start();
client.send(StompMessages.createStompMessage(DESTINATION_QUEUE_ONE, "msg1"));
client.send(StompMessages.createStompMessage(DESTINATION_QUEUE_ONE, "msg2"));
Assert.assertTrue("No latch timeout", outboundLatch.await(10, TimeUnit.SECONDS));