@Test
public void testInitialize() {

	ClusterLinkImpl clusterLinkImpl = getClusterLinkImpl(2);
	Assert.assertNotNull(clusterLinkImpl.getExecutorService());
	List<TestClusterChannel> clusterChannels =
		TestClusterChannel.getClusterChannels();
	Assert.assertEquals(
		clusterChannels.toString(), 2, clusterChannels.size());
	for (TestClusterChannel clusterChannel : clusterChannels) {
		Assert.assertFalse(clusterChannel.isClosed());
		CountDownLatch countDownLatch = ReflectionTestUtil.getFieldValue(
			clusterChannel.getClusterReceiver(), "_countDownLatch");
		Assert.assertEquals(0, countDownLatch.getCount());
	}
}