final QueueingChannelCallbacks channelCallbacks = QueueingChannelCallbacks.create (channelController, exceptions);
final CallbackIsolate channelCallbacksIsolate = reactor.createIsolate ();
Assert.assertTrue (reactor.assignHandler (channelCallbacksProxy, channelCallbacks, channelCallbacksIsolate).await (BasicChannelTest.defaultPollTimeout));
for (int index = 0; index < BasicChannelTest.defaultTries; index++) {
final ChannelMessage outboundMessage = RandomMessageGenerator.defaultInstance.generateChannelMessage ();
Assert.assertTrue (channelController.send (outboundMessage).await (BasicChannelTest.defaultPollTimeout));
final ChannelMessage inboundMessage = channelCallbacks.queue.poll (BasicChannelTest.defaultPollTimeout, TimeUnit.MILLISECONDS);
Assert.assertNotNull (inboundMessage);
Assert.assertEquals (outboundMessage.metaData, inboundMessage.metaData);
Assert.assertEquals (outboundMessage.data, inboundMessage.data);
}