@Test void testAcceptWithUserBreakException() { Event<SdxDiagnosticsWaitRequest> event = initEvent(); UserBreakException exception = new UserBreakException(); doThrow(exception).when(diagnosticsFlowService).waitForDiagnosticsCollection(anyLong(), any(), any()); underTest.accept(event); SdxDiagnosticsFailedEvent sdxDiagnosticsFailedEvent = new SdxDiagnosticsFailedEvent(1L, "userId", Map.of(), exception); Mockito.verify(eventBus, Mockito.times(1)).notify(eq(sdxDiagnosticsFailedEvent.selector()), any(Event.class)); }
@Override public String selector() { return "SdxDiagnosticsWaitRequest"; }
SdxDiagnosticsCollectionHandler extends ExceptionCatcherEventHandler<SdxDiagnosticsWaitRequest> { @Override public String selector() { return "SdxDiagnosticsWaitRequest"; } }
SdxDiagnosticsCollectionHandler extends ExceptionCatcherEventHandler<SdxDiagnosticsWaitRequest> { @Override public String selector() { return "SdxDiagnosticsWaitRequest"; }  }
SdxDiagnosticsCollectionHandler extends ExceptionCatcherEventHandler<SdxDiagnosticsWaitRequest> { @Override public String selector() { return "SdxDiagnosticsWaitRequest"; }  @Override String selector(); }
SdxDiagnosticsCollectionHandler extends ExceptionCatcherEventHandler<SdxDiagnosticsWaitRequest> { @Override public String selector() { return "SdxDiagnosticsWaitRequest"; }  @Override String selector();  }