@Test void start_WillDelegate() { switchingEventProcessor.start(); verify(subscribingEventProcessor).start(); }
@Override @StartHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) public void start() { currentEventProcessor.start(); }
SwitchingEventProcessor implements ReplayableEventProcessor { @Override @StartHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) public void start() { currentEventProcessor.start(); } }
SwitchingEventProcessor implements ReplayableEventProcessor { @Override @StartHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) public void start() { currentEventProcessor.start(); } SwitchingEventProcessor(SubscribingEventProcessor subscribingEventProcessor,
                                   MarkerAwareTrackingEventProcessor markerAwareTrackingEventProcessor); }
SwitchingEventProcessor implements ReplayableEventProcessor { @Override @StartHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) public void start() { currentEventProcessor.start(); } SwitchingEventProcessor(SubscribingEventProcessor subscribingEventProcessor,
                                   MarkerAwareTrackingEventProcessor markerAwareTrackingEventProcessor); @Override void startReplay(TrackingToken startPosition, ReplayMarkerEvent replayMarkerEvent); @Override ListenerRegistry registerReplayCompletionListener(Consumer<ReplayableEventProcessor> listener); @SuppressWarnings("PMD.CompareObjectsWithEquals") @Override boolean isReplaying(); @Override String getName(); @Override List<MessageHandlerInterceptor<? super EventMessage<?>>> getHandlerInterceptors(); @Override @StartHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) void start(); @Override @ShutdownHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) void shutDown(); @Override Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> handlerInterceptor); }
SwitchingEventProcessor implements ReplayableEventProcessor { @Override @StartHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) public void start() { currentEventProcessor.start(); } SwitchingEventProcessor(SubscribingEventProcessor subscribingEventProcessor,
                                   MarkerAwareTrackingEventProcessor markerAwareTrackingEventProcessor); @Override void startReplay(TrackingToken startPosition, ReplayMarkerEvent replayMarkerEvent); @Override ListenerRegistry registerReplayCompletionListener(Consumer<ReplayableEventProcessor> listener); @SuppressWarnings("PMD.CompareObjectsWithEquals") @Override boolean isReplaying(); @Override String getName(); @Override List<MessageHandlerInterceptor<? super EventMessage<?>>> getHandlerInterceptors(); @Override @StartHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) void start(); @Override @ShutdownHandler(phase = LOCAL_MESSAGE_HANDLER_REGISTRATIONS) void shutDown(); @Override Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> handlerInterceptor);  }