@Test void getName_WillDelegate() { when(subscribingEventProcessor.getName()).thenReturn("Jim"); assertEquals("Jim", switchingEventProcessor.getName()); }
@Override public String getName() { return currentEventProcessor.getName(); }
SwitchingEventProcessor implements ReplayableEventProcessor { @Override public String getName() { return currentEventProcessor.getName(); } }
SwitchingEventProcessor implements ReplayableEventProcessor { @Override public String getName() { return currentEventProcessor.getName(); } SwitchingEventProcessor(SubscribingEventProcessor subscribingEventProcessor,
                                   MarkerAwareTrackingEventProcessor markerAwareTrackingEventProcessor); }
SwitchingEventProcessor implements ReplayableEventProcessor { @Override public String getName() { return currentEventProcessor.getName(); } 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 public String getName() { return currentEventProcessor.getName(); } 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);  }