@Test public void testOnChannelClose() { brokerHousekeepingService.onChannelClose("127.0.0.1:9876", null); }
@Override public void onChannelClose(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); }
ManageHousekeepingService implements ChannelEventListener { @Override public void onChannelClose(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } }
ManageHousekeepingService implements ChannelEventListener { @Override public void onChannelClose(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } ManageHousekeepingService(NameSrvController namesrvController); }
ManageHousekeepingService implements ChannelEventListener { @Override public void onChannelClose(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } ManageHousekeepingService(NameSrvController namesrvController); @Override void onChannelConnect(String remoteAddr, Channel channel); @Override void onChannelClose(String remoteAddr, Channel channel); @Override void onChannelException(String remoteAddr, Channel channel); @Override void onChannelIdle(String remoteAddr, Channel channel); }
ManageHousekeepingService implements ChannelEventListener { @Override public void onChannelClose(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } ManageHousekeepingService(NameSrvController namesrvController); @Override void onChannelConnect(String remoteAddr, Channel channel); @Override void onChannelClose(String remoteAddr, Channel channel); @Override void onChannelException(String remoteAddr, Channel channel); @Override void onChannelIdle(String remoteAddr, Channel channel);  }