org.kie.api.runtime.Environment.set()方法的使用及代码示例

本文整理了Java中org.kie.api.runtime.Environment.set()方法的一些代码示例，展示了Environment.set()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Environment.set()方法的具体详情如下：
包路径：org.kie.api.runtime.Environment
类名称：Environment
方法名：set

Environment.set介绍

暂无

代码示例

代码示例来源：origin: kiegroup/jbpm

public HumanTaskConfigurator entityManagerFactory(EntityManagerFactory emf) {
if (emf == null) {
return this;
}
environment.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf);

return this;
}

代码示例来源：origin: kiegroup/jbpm

/**
* Adds element to the drools/jbpm environment - the value must be thread save as it will be shared between all
* RuntimeEngine instances
* @param name name of the environment entry
* @param value value of the environment entry
*/
public void addToEnvironment(String name, Object value) {
this.environment.set(name, value);
this.environmentEntries.put(name, value);
}

代码示例来源：origin: kiegroup/jbpm

protected void addIfPresent(String name, Environment copy) {
Object value = this.environment.get(name);
if (value != null) {
copy.set(name, value);
}
}

代码示例来源：origin: kiegroup/jbpm

public void set(String string, Object o) {
if (string.startsWith("local:")) {
delegate.set(string, o);
return;
}

if (this.environment.get(string) != null) {
throw new IllegalArgumentException("Cannot override value for property " + string);
}
this.environment.set(string, o);
}

代码示例来源：origin: kiegroup/jbpm

@Override
public EntityManager getCommandScopedEntityManager() {
EntityManager em = super.getCommandScopedEntityManager();
// ensure em is set in the environment to cover situation when em is taken from tx directly
// when using per process instance runtime strategy
if (env.get(EnvironmentName.CMD_SCOPED_ENTITY_MANAGER) == null) {
env.set(EnvironmentName.CMD_SCOPED_ENTITY_MANAGER, em);
}

return em;
}

代码示例来源：origin: kiegroup/jbpm

public static Environment createEnvironment(Map context) {
Environment env = EnvironmentFactory.newEnvironment();

UserTransaction ut = (UserTransaction) context.get(TRANSACTION);
if( ut != null ) {
env.set( TRANSACTION, ut);
}

env.set( ENTITY_MANAGER_FACTORY, context.get(ENTITY_MANAGER_FACTORY) );
env.set( TRANSACTION_MANAGER, com.arjuna.ats.jta.TransactionManager.transactionManager() );
env.set( GLOBALS, new MapGlobalResolver() );

return env;
}

代码示例来源：origin: kiegroup/jbpm

protected InternalTaskService newTaskService(TaskServiceFactory factory) {
InternalTaskService internalTaskService = (InternalTaskService) factory.newTaskService();
if (internalTaskService instanceof CommandBasedTaskService) {
((CommandBasedTaskService) internalTaskService).getEnvironment().set(EnvironmentName.DEPLOYMENT_ID, this.getIdentifier());
((CommandBasedTaskService) internalTaskService).getEnvironment().set(EnvironmentName.OBJECT_MARSHALLING_STRATEGIES,
((SimpleRuntimeEnvironment)environment).getEnvironmentTemplate().get(EnvironmentName.OBJECT_MARSHALLING_STRATEGIES));
}

return internalTaskService;
}

代码示例来源：origin: kiegroup/jbpm

@Override
public Void execute(org.kie.api.runtime.Context context) {
KieSession ksession = ((RegistryContext) context).lookup( KieSession.class );
ksession.getEnvironment().set("Active", false);

InternalProcessRuntime processRuntime = ((InternalKnowledgeRuntime) ksession).getProcessRuntime();
((ProcessRuntimeImpl) processRuntime).removeProcessEventListeners();
return null;
}
});

代码示例来源：origin: kiegroup/jbpm

@Override
public Void execute(org.kie.api.runtime.Context context) {
KieSession ksession = ((RegistryContext) context).lookup( KieSession.class );
ksession.getEnvironment().set("Active", true);

InternalProcessRuntime processRuntime = ((InternalKnowledgeRuntime) ksession).getProcessRuntime();
((ProcessRuntimeImpl) processRuntime).initProcessEventListeners();
((ProcessRuntimeImpl) processRuntime).initStartTimers();
return null;
}
});

代码示例来源：origin: kiegroup/jbpm

@Override
public KieSession findKieSessionById(Long sessionId) {
if (sessiOnId== null) {
return null;
}
Environment env = environment.getEnvironment();
env.set(EnvironmentName.DEPLOYMENT_ID, owner);
KieSession ksession = JPAKnowledgeService.loadStatefulKnowledgeSession(sessionId,
environment.getKieBase(), environment.getConfiguration(), env);
addInterceptors(ksession);
return ksession;
}

代码示例来源：origin: kiegroup/jbpm

@Override
public KieSession newKieSession() {
Environment env = environment.getEnvironment();
env.set(EnvironmentName.DEPLOYMENT_ID, owner);
KieSession ksession = kbase.newKieSession(environment.getConfiguration(), env);
this.sessions.put(ksession.getIdentifier(), ksession);

ProcessInstanceManager piManager = ((ProcessRuntimeImpl)((StatefulKnowledgeSessionImpl)ksession).getProcessRuntime()).getProcessInstanceManager();
if (piManager instanceof DefaultProcessInstanceManager) {
((DefaultProcessInstanceManager) piManager).setProcessCounter(processCounter);
}
return ksession;
}

代码示例来源：origin: kiegroup/jbpm

@Override
public KieSession newKieSession() {
Environment env = environment.getEnvironment();
env.set(EnvironmentName.DEPLOYMENT_ID, owner);
KieSession ksession = JPAKnowledgeService.newStatefulKnowledgeSession(
environment.getKieBase(), environment.getConfiguration(), env);
addInterceptors(ksession);
return ksession;
}

代码示例来源：origin: kiegroup/jbpm

@Override
protected StatefulKnowledgeSession createSession(KieBase kbase) {
Environment env = createEnvironment(context);
if( this.useLocking ) {
env.set(USE_PESSIMISTIC_LOCKING, true);
}
return JPAKnowledgeService.newStatefulKnowledgeSession( kbase, null, env);
}

代码示例来源：origin: kiegroup/jbpm

@Override
protected StatefulKnowledgeSession createSession(KieBase kbase) {

EnvironmentBuilder envBuilder = new ProcessStorageEnvironmentBuilder( storage );
Environment env = KieServices.get().newEnvironment();
env.set( EnvironmentName.TRANSACTION_MANAGER,
envBuilder.getTransactionManager() );
env.set( EnvironmentName.PERSISTENCE_CONTEXT_MANAGER,
envBuilder.getPersistenceContextManager() );
return JPAKnowledgeService.newStatefulKnowledgeSession( kbase,
null,
env );
}

代码示例来源：origin: kiegroup/jbpm

@Before
public void setUp() throws Exception {
cOntext= setupWithPoolingDataSource(JBPM_PERSISTENCE_UNIT_NAME);
Environment env = EnvironmentFactory.newEnvironment();
env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, context.get(EnvironmentName.ENTITY_MANAGER_FACTORY));
logService = new JPAAuditLogService(env);
}

代码示例来源：origin: kiegroup/jbpm

private Environment createEnvironment() {
Environment env = PersistenceUtil.createEnvironment(context);
env.set(EnvironmentName.OBJECT_MARSHALLING_STRATEGIES, new ObjectMarshallingStrategy[]{
new JPAPlaceholderResolverStrategy(env),
new SerializablePlaceholderResolverStrategy( ClassObjectMarshallingStrategyAcceptor.DEFAULT )
});
return env;
}

代码示例来源：origin: kiegroup/jbpm

@Override
protected StatefulKnowledgeSession disposeAndReloadSession(StatefulKnowledgeSession ksession, long ksessionId,
KieBase kbase) {
ksession.dispose();
EnvironmentBuilder envBuilder = new ProcessStorageEnvironmentBuilder( storage );
Environment env = KieServices.get().newEnvironment();
env.set( EnvironmentName.TRANSACTION_MANAGER,
envBuilder.getTransactionManager() );
env.set( EnvironmentName.PERSISTENCE_CONTEXT_MANAGER,
envBuilder.getPersistenceContextManager() );

return JPAKnowledgeService.loadStatefulKnowledgeSession( ksessionId, kbase, null, env );
}

代码示例来源：origin: kiegroup/jbpm

@Before
public void setUp() throws Exception {
String methodName = testName.getMethodName();
cOntext= setupWithPoolingDataSource(JBPM_PERSISTENCE_UNIT_NAME);

env = createEnvironment(context);
if( useLocking ) {
env.set(EnvironmentName.USE_PESSIMISTIC_LOCKING, true);
}
TestEventEmitter.clear();
}

代码示例来源：origin: kiegroup/jbpm

@BeforeClass
public static void setup() throws Exception {
setUpDataSource();

// clear logs
Environment env = EnvironmentFactory.newEnvironment();
env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf);
logService = new JPAAuditLogService(env);
logService.clear();
}

代码示例来源：origin: kiegroup/jbpm

@Before
public void before() {
cOntext= setupWithPoolingDataSource(JBPM_PERSISTENCE_UNIT_NAME);
Environment env = createEnvironment(context);
if( useLocking ) {
env.set(EnvironmentName.USE_PESSIMISTIC_LOCKING, true);
}
ksession = JPAKnowledgeService.newStatefulKnowledgeSession(createKnowledgeBase(), null, env);
assertTrue("Valid KnowledgeSession could not be created.", ksession != null && ksession.getIdentifier() > 0);
listener = new ProcessListener();
ksession.addEventListener(listener);
}