@Test public void shouldCompleteRunningWhenPipelineFailsDuringInvocations () { final RuntimeException failure = new RuntimeException( "expected" ); when( operator.invoke( anyBoolean(), anyObject(), anyObject() ) ).thenThrow( failure ); thread.start(); assertTrueEventually( () -> assertEquals( runner.getStatus(), COMPLETED ), 10 ); verify( supervisor ).notifyPipelineReplicaFailed( id, failure ); }
public PipelineReplicaRunnerStatus getStatus () { synchronized ( monitor ) { return status; } }
PipelineReplicaRunner implements Runnable { public PipelineReplicaRunnerStatus getStatus () { synchronized ( monitor ) { return status; } } }
PipelineReplicaRunner implements Runnable { public PipelineReplicaRunnerStatus getStatus () { synchronized ( monitor ) { return status; } } PipelineReplicaRunner( final JokerConfig config,
                            final PipelineReplica pipeline,
                            final Supervisor supervisor,
                            final DownstreamCollector downstreamCollector ); }
PipelineReplicaRunner implements Runnable { public PipelineReplicaRunnerStatus getStatus () { synchronized ( monitor ) { return status; } } PipelineReplicaRunner( final JokerConfig config,
                            final PipelineReplica pipeline,
                            final Supervisor supervisor,
                            final DownstreamCollector downstreamCollector ); PipelineReplicaRunnerStatus getStatus(); void run(); }
PipelineReplicaRunner implements Runnable { public PipelineReplicaRunnerStatus getStatus () { synchronized ( monitor ) { return status; } } PipelineReplicaRunner( final JokerConfig config,
                            final PipelineReplica pipeline,
                            final Supervisor supervisor,
                            final DownstreamCollector downstreamCollector ); PipelineReplicaRunnerStatus getStatus(); void run();  }