@Test public void onClientDisconnected() { }
@EventListener public void onClientDisconnected(TopologyEvents.ApplicationDisconnected event) { clients.remove(event.getClientStreamId()); cache.remove(event.getClientStreamId()); }
ProcessorsInfoTarget implements ClientProcessors { @EventListener public void onClientDisconnected(TopologyEvents.ApplicationDisconnected event) { clients.remove(event.getClientStreamId()); cache.remove(event.getClientStreamId()); } }
ProcessorsInfoTarget implements ClientProcessors { @EventListener public void onClientDisconnected(TopologyEvents.ApplicationDisconnected event) { clients.remove(event.getClientStreamId()); cache.remove(event.getClientStreamId()); } ProcessorsInfoTarget(); }
ProcessorsInfoTarget implements ClientProcessors { @EventListener public void onClientDisconnected(TopologyEvents.ApplicationDisconnected event) { clients.remove(event.getClientStreamId()); cache.remove(event.getClientStreamId()); } ProcessorsInfoTarget(); @EventListener EventProcessorStatusUpdated onEventProcessorStatusChange(EventProcessorStatusUpdate event); @EventListener void onClientConnected(TopologyEvents.ApplicationConnected event); @EventListener void onClientDisconnected(TopologyEvents.ApplicationDisconnected event); @Nonnull @Override Iterator<ClientProcessor> iterator(); }
ProcessorsInfoTarget implements ClientProcessors { @EventListener public void onClientDisconnected(TopologyEvents.ApplicationDisconnected event) { clients.remove(event.getClientStreamId()); cache.remove(event.getClientStreamId()); } ProcessorsInfoTarget(); @EventListener EventProcessorStatusUpdated onEventProcessorStatusChange(EventProcessorStatusUpdate event); @EventListener void onClientConnected(TopologyEvents.ApplicationConnected event); @EventListener void onClientDisconnected(TopologyEvents.ApplicationDisconnected event); @Nonnull @Override Iterator<ClientProcessor> iterator();  }