@Test public void onClientConnected() { }
@EventListener public void onClientConnected(TopologyEvents.ApplicationConnected event) { clients.put(event.getClientStreamId(), event.getComponentName()); }
ProcessorsInfoTarget implements ClientProcessors { @EventListener public void onClientConnected(TopologyEvents.ApplicationConnected event) { clients.put(event.getClientStreamId(), event.getComponentName()); } }
ProcessorsInfoTarget implements ClientProcessors { @EventListener public void onClientConnected(TopologyEvents.ApplicationConnected event) { clients.put(event.getClientStreamId(), event.getComponentName()); } ProcessorsInfoTarget(); }
ProcessorsInfoTarget implements ClientProcessors { @EventListener public void onClientConnected(TopologyEvents.ApplicationConnected event) { clients.put(event.getClientStreamId(), event.getComponentName()); } 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 onClientConnected(TopologyEvents.ApplicationConnected event) { clients.put(event.getClientStreamId(), event.getComponentName()); } ProcessorsInfoTarget(); @EventListener EventProcessorStatusUpdated onEventProcessorStatusChange(EventProcessorStatusUpdate event); @EventListener void onClientConnected(TopologyEvents.ApplicationConnected event); @EventListener void onClientDisconnected(TopologyEvents.ApplicationDisconnected event); @Nonnull @Override Iterator<ClientProcessor> iterator();  }