Examples of saveContext()


Examples of org.openbp.server.context.TokenContextService.saveContext()

    tokenContextService.saveContext(tc2);

    tc4 = tokenContextService.getContextById(tc4.getId());
    tc4.setLifecycleState(LifecycleState.SUSPENDED);
    tc4.setLifecycleRequest(LifecycleRequest.RESUME);
    tokenContextService.saveContext(tc4);

    tokenContextService.commit();

    getProcessFacade().executePendingContextsInThisThread();
    assertEquals("Done", TestCaseSyncMgr.getInstance().getSignal(null, "TestSignal2"));
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

      }
    }

    if (updateContext)
    {
      contextService.saveContext(dbContext);
      engine.commit();
    }

    // Make the rolled-back context the current one
    return dbContext;
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

          sessionRegistry.registerSession(context.getId(), context, sessionTimeout);
        }
      }

      TokenContextService contextService = engine.getTokenContextService();
      contextService.saveContext(context);
      engine.commit();

      do
      {
        executeNextStep();
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

      // This node type requires persistence of the process state
      LogUtil.trace(getClass(), "Suspending token (immediate suspend). [{0}]", context);

      engine.changeTokenState(context, LifecycleState.SUSPENDED, LifecycleRequest.NONE);

      contextService.saveContext(context);
      engine.commit();
    }
    else if (lifecycleRequest == LifecycleRequest.STOP)
    {
      // Normally terminate processing
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

        case ControlLink.TA_COMMIT_BEGIN:
        begin = true;
        // Fallthrough

        case ControlLink.TA_COMMIT:
        contextService.saveContext(context);
        engine.commit();
        break;

        case ControlLink.TA_ROLLBACK_BEGIN:
        begin = true;
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

      {
        // There is a suspension request for the next transaction control, serve it.
        LogUtil.trace(getClass(), "Suspending token (transaction suspend). [{0}]", context);

        engine.changeTokenState(context, LifecycleState.SUSPENDED, LifecycleRequest.NONE);
        contextService.saveContext(context);
        engine.commit();
      }
    }

    if (context.getCurrentSocket() == oldCurrentSocket)
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

    Object contextId = context.getId();
    engine.rollback();

    context = contextService.getContextById(contextId);
    engine.changeTokenState(context, lifecycleState, LifecycleRequest.NONE);
    contextService.saveContext(context);
    engine.commit();

    // TODO Fix 3 What to do with child/root context? Maybe call endToken with a parameter?
  }
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

    {
      // Our top-level context ends here (and will implicitely end all child contexts)
      rootContext.setLifecycleRequest(LifecycleRequest.STOP);

      TokenContextService contextService = getEngine().getTokenContextService();
      contextService.saveContext(rootContext);
    }
  }
}
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

        // Continue the parent context in a new thread
        parentContext.setCurrentSocket(parentNextSocket);
        parentContext.setLifecycleRequest(LifecycleRequest.RESUME);

        TokenContextService contextService = getEngine().getTokenContextService();
        contextService.saveContext(parentContext);
      }
    }
    else
    {
      nextSocket = node.getDefaultExitSocket();
View Full Code Here

Examples of org.openbp.server.context.TokenContextService.saveContext()

      }
    }

    if (updateContext)
    {
      contextService.saveContext(dbContext);
      if (isCommitTokenContextChangesEnabled())
      {
        engine.commit();
      }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.