ClusterLinkImpl implements ClusterLink { @Deactivate protected void deactivate() { if (_clusterChannels != null) { for (ClusterChannel clusterChannel : _clusterChannels) { clusterChannel.close(); } } _localAddresses = null; _clusterChannels = null; _clusterReceivers = null; if (_executorService != null) { _executorService.shutdownNow(); } _executorService = null; }  @Override boolean isEnabled(); @Override void sendMulticastMessage(Message message, Priority priority); @Override void sendUnicastMessage(
		Address address, Message message, Priority priority);  }
@Test public void testDeactivate() { ClusterLinkImpl clusterLinkImpl = getClusterLinkImpl(1); List<TestClusterChannel> clusterChannels = TestClusterChannel.getClusterChannels(); Assert.assertEquals( clusterChannels.toString(), 1, clusterChannels.size()); TestClusterChannel clusterChannel = clusterChannels.get(0); ExecutorService executorService = clusterLinkImpl.getExecutorService(); Assert.assertFalse(clusterChannel.isClosed()); Assert.assertFalse(executorService.isShutdown()); clusterLinkImpl.deactivate(); Assert.assertTrue(clusterChannel.isClosed()); Assert.assertTrue(executorService.isShutdown()); }