ClusterLinkImpl implements ClusterLink { @Override public void sendUnicastMessage( Address address, Message message, Priority priority) { if (_localAddresses.contains(address)) { sendLocalMessage(message); return; } ClusterChannel clusterChannel = getChannel(priority); clusterChannel.sendUnicastMessage(message, address); }  @Override boolean isEnabled(); @Override void sendMulticastMessage(Message message, Priority priority); @Override void sendUnicastMessage(
		Address address, Message message, Priority priority);  }
@Test public void testSendUnicastMessage() { ClusterLinkImpl clusterLinkImpl = getClusterLinkImpl(1); List<Serializable> multicastMessages = TestClusterChannel.getMulticastMessages(); List<ObjectValuePair<Serializable, Address>> unicastMessages = TestClusterChannel.getUnicastMessages(); Assert.assertTrue( multicastMessages.toString(), multicastMessages.isEmpty()); Assert.assertTrue( unicastMessages.toString(), unicastMessages.isEmpty()); Message message = new Message(); Address address = new TestAddress(-1); clusterLinkImpl.sendUnicastMessage(address, message, Priority.LEVEL1); Assert.assertTrue( multicastMessages.toString(), multicastMessages.isEmpty()); Assert.assertEquals( unicastMessages.toString(), 1, unicastMessages.size()); ObjectValuePair<Serializable, Address> unicastMessage = unicastMessages.get(0); Assert.assertSame(message, unicastMessage.getKey()); Assert.assertSame(address, unicastMessage.getValue()); }