connection.send(connectionInfo);
connection.send(sessionInfo);
ConsumerInfo consumerInfo = createConsumerInfo(sessionInfo, destination);
connection.send(consumerInfo);
producerInfo = createProducerInfo(sessionInfo);
connection.send(producerInfo);
for(int i=0; i < MESSAGE_COUNT/2; i++) {
Message m = receiveMessage(connection);
assertNotNull("Should have received message "+expected.get(0)+" by now!", m);
assertEquals(expected.remove(0), m.getMessageId().toString());