test_class.declarator: sut
test_class.modifier: private
test_class.original_string: private SagaExecutionTask sut;
test_class.type: SagaExecutionTask
test_class.var_name: sut
test_class.declarator: timeoutManager
test_class.modifier: private
test_class.original_string: private TimeoutManager timeoutManager;
test_class.type: TimeoutManager
test_class.var_name: timeoutManager
test_class.declarator: storage
test_class.modifier: private
test_class.original_string: private StateStorage storage;
test_class.type: StateStorage
test_class.var_name: storage
test_class.declarator: saga
test_class.modifier: private
test_class.original_string: private Saga saga;
test_class.type: Saga
test_class.var_name: saga
test_class.declarator: sagaInstanceInfo
test_class.modifier: private
test_class.original_string: private SagaInstanceInfo sagaInstanceInfo;
test_class.type: SagaInstanceInfo
test_class.var_name: sagaInstanceInfo
test_class.declarator: state
test_class.modifier: private
test_class.original_string: private SagaState state;
test_class.type: SagaState
test_class.var_name: state
test_class.declarator: context
test_class.modifier: private
test_class.original_string: private CurrentExecutionContext context;
test_class.type: CurrentExecutionContext
test_class.var_name: context
test_class.declarator: theMessage
test_class.modifier: private
test_class.original_string: private Object theMessage;
test_class.type: Object
test_class.var_name: theMessage
test_class.declarator: invoker
test_class.modifier: private
test_class.original_string: private HandlerInvoker invoker;
test_class.type: HandlerInvoker
test_class.var_name: invoker
test_class.declarator: instanceResolver
test_class.modifier: private
test_class.original_string: private InstanceResolver instanceResolver;
test_class.type: InstanceResolver
test_class.var_name: instanceResolver
test_class.declarator: module
test_class.modifier: private
test_class.original_string: private SagaModule module;
test_class.type: SagaModule
test_class.var_name: module
test_class.declarator: interceptor
test_class.modifier: private
test_class.original_string: private SagaLifetimeInterceptor interceptor;
test_class.type: SagaLifetimeInterceptor
test_class.var_name: interceptor
test_class.declarator: thrown = ExpectedException.none()
test_class.modifier: @Rule
      public
test_class.original_string: @Rule
      public ExpectedException thrown = ExpectedException.none();
test_class.type: ExpectedException
test_class.var_name: thrown
test_class.file: saga-lib/src/test/java/com/codebullets/sagalib/processing/SagaExecutionTaskTest.java
test_class.identifier: SagaExecutionTaskTest
test_case.body: @Test
      public void run_sagaNotCompleted_rememberStoredIdInContext() {
          // given
          final String sagaId = RandomStringUtils.randomAlphanumeric(10);
          when(state.getSagaId()).thenReturn(sagaId);
          when(saga.isFinished()).thenReturn(false);
  
          // when
          sut.run();
  
          // then
          verify(context).recordSagaStateStored(sagaId);
      }
test_case.class_method_signature: SagaExecutionTaskTest.run_sagaNotCompleted_rememberStoredIdInContext()
test_case.full_signature: @Test public void run_sagaNotCompleted_rememberStoredIdInContext()
test_case.identifier: run_sagaNotCompleted_rememberStoredIdInContext
test_case.invocations: randomAlphanumeric thenReturn when getSagaId thenReturn when isFinished run recordSagaStateStored verify
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void run_sagaNotCompleted_rememberStoredIdInContext()
focal_class.declarator: LOG = LoggerFactory.getLogger(SagaExecutionTask.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(SagaExecutionTask.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: invoker
focal_class.modifier: private final
focal_class.original_string: private final HandlerInvoker invoker;
focal_class.type: HandlerInvoker
focal_class.var_name: invoker
focal_class.declarator: env
focal_class.modifier: private final
focal_class.original_string: private final SagaEnvironment env;
focal_class.type: SagaEnvironment
focal_class.var_name: env
focal_class.declarator: taskLookupContext
focal_class.modifier: private final
focal_class.original_string: private final LookupContext taskLookupContext;
focal_class.type: LookupContext
focal_class.var_name: taskLookupContext
focal_class.declarator: parentContext
focal_class.modifier: @Nullable
      private final
focal_class.original_string: @Nullable
      private final ExecutionContext parentContext;
focal_class.type: ExecutionContext
focal_class.var_name: parentContext
focal_class.file: saga-lib/src/main/java/com/codebullets/sagalib/processing/SagaExecutionTask.java
focal_class.identifier: SagaExecutionTask
focal_class.interfaces: implements ExecutedRunnable
focal_class.class_method_signature: SagaExecutionTask.SagaExecutionTask(
              final SagaEnvironment environment,
              final HandlerInvoker invoker,
              final Object message,
              final Map<HeaderName<?>, Object> headers,
              @Nullable final ExecutionContext parentContext)
focal_class.full_signature: @Inject  SagaExecutionTask(
              final SagaEnvironment environment,
              final HandlerInvoker invoker,
              final Object message,
              final Map<HeaderName<?>, Object> headers,
              @Nullable final ExecutionContext parentContext)
focal_class.identifier: SagaExecutionTask
focal_class.modifiers: @Inject
focal_class.parameters: (
              final SagaEnvironment environment,
              final HandlerInvoker invoker,
              final Object message,
              final Map<HeaderName<?>, Object> headers,
              @Nullable final ExecutionContext parentContext)
focal_class.signature:  SagaExecutionTask(
              final SagaEnvironment environment,
              final HandlerInvoker invoker,
              final Object message,
              final Map<HeaderName<?>, Object> headers,
              @Nullable final ExecutionContext parentContext)
focal_class.class_method_signature: SagaExecutionTask.handle()
focal_class.full_signature: public void handle()
focal_class.identifier: handle
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void handle()
focal_class.class_method_signature: SagaExecutionTask.startExecutionChain(final LookupContext messageLookupContext)
focal_class.full_signature: private boolean startExecutionChain(final LookupContext messageLookupContext)
focal_class.identifier: startExecutionChain
focal_class.modifiers: private
focal_class.parameters: (final LookupContext messageLookupContext)
focal_class.return: boolean
focal_class.signature: boolean startExecutionChain(final LookupContext messageLookupContext)
focal_class.class_method_signature: SagaExecutionTask.executeHandlersForMessage(final LookupContext messageLookupContext, final CurrentExecutionContext executionContext)
focal_class.full_signature: private boolean executeHandlersForMessage(final LookupContext messageLookupContext, final CurrentExecutionContext executionContext)
focal_class.identifier: executeHandlersForMessage
focal_class.modifiers: private
focal_class.parameters: (final LookupContext messageLookupContext, final CurrentExecutionContext executionContext)
focal_class.return: boolean
focal_class.signature: boolean executeHandlersForMessage(final LookupContext messageLookupContext, final CurrentExecutionContext executionContext)
focal_class.class_method_signature: SagaExecutionTask.invokeSagas(final CurrentExecutionContext context, final Iterable<SagaInstanceInfo> sagaDescriptions, final Object invokeParam)
focal_class.full_signature: private void invokeSagas(final CurrentExecutionContext context, final Iterable<SagaInstanceInfo> sagaDescriptions, final Object invokeParam)
focal_class.identifier: invokeSagas
focal_class.modifiers: private
focal_class.parameters: (final CurrentExecutionContext context, final Iterable<SagaInstanceInfo> sagaDescriptions, final Object invokeParam)
focal_class.return: void
focal_class.signature: void invokeSagas(final CurrentExecutionContext context, final Iterable<SagaInstanceInfo> sagaDescriptions, final Object invokeParam)
focal_class.class_method_signature: SagaExecutionTask.interceptorHandling(final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.full_signature: private void interceptorHandling(final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.identifier: interceptorHandling
focal_class.modifiers: private
focal_class.parameters: (final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.return: void
focal_class.signature: void interceptorHandling(final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.class_method_signature: SagaExecutionTask.interceptorHandlingExecuted(final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.full_signature: private void interceptorHandlingExecuted(final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.identifier: interceptorHandlingExecuted
focal_class.modifiers: private
focal_class.parameters: (final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.return: void
focal_class.signature: void interceptorHandlingExecuted(final Saga saga, final ExecutionContext context, final Object invokeParam)
focal_class.class_method_signature: SagaExecutionTask.interceptorFinished(final Saga saga, final ExecutionContext context)
focal_class.full_signature: private void interceptorFinished(final Saga saga, final ExecutionContext context)
focal_class.identifier: interceptorFinished
focal_class.modifiers: private
focal_class.parameters: (final Saga saga, final ExecutionContext context)
focal_class.return: void
focal_class.signature: void interceptorFinished(final Saga saga, final ExecutionContext context)
focal_class.class_method_signature: SagaExecutionTask.interceptorStart(final SagaInstanceInfo sagaDescription, final ExecutionContext context, final Object invokeParam)
focal_class.full_signature: private void interceptorStart(final SagaInstanceInfo sagaDescription, final ExecutionContext context, final Object invokeParam)
focal_class.identifier: interceptorStart
focal_class.modifiers: private
focal_class.parameters: (final SagaInstanceInfo sagaDescription, final ExecutionContext context, final Object invokeParam)
focal_class.return: void
focal_class.signature: void interceptorStart(final SagaInstanceInfo sagaDescription, final ExecutionContext context, final Object invokeParam)
focal_class.class_method_signature: SagaExecutionTask.setHeaders(final CurrentExecutionContext context)
focal_class.full_signature: @SuppressWarnings("unchecked") private void setHeaders(final CurrentExecutionContext context)
focal_class.identifier: setHeaders
focal_class.modifiers: @SuppressWarnings("unchecked") private
focal_class.parameters: (final CurrentExecutionContext context)
focal_class.return: void
focal_class.signature: void setHeaders(final CurrentExecutionContext context)
focal_class.class_method_signature: SagaExecutionTask.setSagaExecutionContext(final Saga saga, final ExecutionContext context)
focal_class.full_signature: private void setSagaExecutionContext(final Saga saga, final ExecutionContext context)
focal_class.identifier: setSagaExecutionContext
focal_class.modifiers: private
focal_class.parameters: (final Saga saga, final ExecutionContext context)
focal_class.return: void
focal_class.signature: void setSagaExecutionContext(final Saga saga, final ExecutionContext context)
focal_class.class_method_signature: SagaExecutionTask.updateStateStorage(final SagaInstanceInfo description, final CurrentExecutionContext context)
focal_class.full_signature: private void updateStateStorage(final SagaInstanceInfo description, final CurrentExecutionContext context)
focal_class.identifier: updateStateStorage
focal_class.modifiers: private
focal_class.parameters: (final SagaInstanceInfo description, final CurrentExecutionContext context)
focal_class.return: void
focal_class.signature: void updateStateStorage(final SagaInstanceInfo description, final CurrentExecutionContext context)
focal_class.class_method_signature: SagaExecutionTask.cleanupSagaSate(final String sagaId)
focal_class.full_signature: private void cleanupSagaSate(final String sagaId)
focal_class.identifier: cleanupSagaSate
focal_class.modifiers: private
focal_class.parameters: (final String sagaId)
focal_class.return: void
focal_class.signature: void cleanupSagaSate(final String sagaId)
focal_class.class_method_signature: SagaExecutionTask.run()
focal_class.full_signature: @Override public void run()
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void run()
focal_class.class_method_signature: SagaExecutionTask.message()
focal_class.full_signature: @Override public Object message()
focal_class.identifier: message
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Object
focal_class.signature: Object message()
focal_class.class_method_signature: SagaExecutionTask.getHeaderValue(final HeaderName<T> header)
focal_class.full_signature: @Override public Optional<T> getHeaderValue(final HeaderName<T> header)
focal_class.identifier: getHeaderValue
focal_class.modifiers: @Override public
focal_class.parameters: (final HeaderName<T> header)
focal_class.return: Optional<T>
focal_class.signature: Optional<T> getHeaderValue(final HeaderName<T> header)
focal_method.body: @Override
      public void run() {
          try {
              handle();
          } catch (Exception e) {
              Throwables.throwIfUnchecked(e);
              throw new RuntimeException(e);
          }
      }
focal_method.class_method_signature: SagaExecutionTask.run()
focal_method.full_signature: @Override public void run()
focal_method.identifier: run
focal_method.invocations: handle throwIfUnchecked
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void run()