@Test public void onMerge() { assertTrue(refreshed.isEmpty()); testSubject.on(new EventProcessorEvents.MergeSegmentsSucceeded(context, "clientB", "ProcessorB")); assertEquals(refreshed, singletonList(new EventProcessorIdentifier("ProcessorB", ""))); }
@EventListener public void on(EventProcessorEvents.MergeSegmentsSucceeded event) { refresh(event.context(), event.clientId(), event.processorName()); }
EventProcessorResultListener { @EventListener public void on(EventProcessorEvents.MergeSegmentsSucceeded event) { refresh(event.context(), event.clientId(), event.processorName()); } }
EventProcessorResultListener { @EventListener public void on(EventProcessorEvents.MergeSegmentsSucceeded event) { refresh(event.context(), event.clientId(), event.processorName()); } @Autowired  EventProcessorResultListener(EventProcessorStatusRefresh refreshEventProcessorStatus,
                                        EventProcessorIdentifierProvider eventProcessorIdentifierProvider);  EventProcessorResultListener(BiConsumer<String, EventProcessorIdentifier> refreshOperation,
                                        ProcessorProvider eventProcessorIdentifierProvider); }
EventProcessorResultListener { @EventListener public void on(EventProcessorEvents.MergeSegmentsSucceeded event) { refresh(event.context(), event.clientId(), event.processorName()); } @Autowired  EventProcessorResultListener(EventProcessorStatusRefresh refreshEventProcessorStatus,
                                        EventProcessorIdentifierProvider eventProcessorIdentifierProvider);  EventProcessorResultListener(BiConsumer<String, EventProcessorIdentifier> refreshOperation,
                                        ProcessorProvider eventProcessorIdentifierProvider); @EventListener void on(EventProcessorEvents.MergeSegmentsSucceeded event); @EventListener void on(EventProcessorEvents.SplitSegmentsSucceeded event); }
EventProcessorResultListener { @EventListener public void on(EventProcessorEvents.MergeSegmentsSucceeded event) { refresh(event.context(), event.clientId(), event.processorName()); } @Autowired  EventProcessorResultListener(EventProcessorStatusRefresh refreshEventProcessorStatus,
                                        EventProcessorIdentifierProvider eventProcessorIdentifierProvider);  EventProcessorResultListener(BiConsumer<String, EventProcessorIdentifier> refreshOperation,
                                        ProcessorProvider eventProcessorIdentifierProvider); @EventListener void on(EventProcessorEvents.MergeSegmentsSucceeded event); @EventListener void on(EventProcessorEvents.SplitSegmentsSucceeded event);  }