@Test public void testOnChannelIdle() { brokerHousekeepingService.onChannelException("127.0.0.1:9876", null); }
@Override public void onChannelIdle(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); }
BrokerHousekeepingService implements ChannelEventListener { @Override public void onChannelIdle(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } }
BrokerHousekeepingService implements ChannelEventListener { @Override public void onChannelIdle(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } BrokerHousekeepingService(NamesrvController namesrvController); }
BrokerHousekeepingService implements ChannelEventListener { @Override public void onChannelIdle(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } BrokerHousekeepingService(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); }
BrokerHousekeepingService implements ChannelEventListener { @Override public void onChannelIdle(String remoteAddr, Channel channel) { this.namesrvController.getRouteInfoManager().onChannelDestroy(remoteAddr, channel); } BrokerHousekeepingService(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);  }