[rules-users] External storage and timers

[didierC]

Hi,

We want to use the external storage API for our Fusion project (Drools 6.0 -
beta2).
We have temporal based rules and when we load an existing session, we get:
...
Caused by: java.lang.NullPointerException
	at
org.drools.core.common.Scheduler$ActivationTimerInputMarshaller.deserialize(Scheduler.java:238)
	at
org.drools.core.marshalling.impl.ProtobufInputMarshaller.readTimer(ProtobufInputMarshaller.java:627)
	at
org.drools.core.marshalling.impl.ProtobufInputMarshaller.readSession(ProtobufInputMarshaller.java:282)
	at
org.drools.core.marshalling.impl.ProtobufInputMarshaller.readSession(ProtobufInputMarshaller.java:154)
	at
org.drools.core.marshalling.impl.ProtobufMarshaller.unmarshall(ProtobufMarshaller.java:114)
	at
org.drools.core.marshalling.impl.ProtobufMarshaller.unmarshall(ProtobufMarshaller.java:56)
	at
org.drools.persistence.SessionMarshallingHelper.loadSnapshot(SessionMarshallingHelper.java:83)
	... 35 more

I can reproduce the problem in a simple test case:
	
public class TestStorage {

	private SimpleKnowledgeSessionStorage storage;

	@Before
	public void initStorage() {
		storage = new SimpleKnowledgeSessionStorage();
	}

	@Test
	public void testStorageWithTimer() throws InterruptedException {
		KieSession session = getSession(null);
		int id = session.getId();

		String rule = "package test\n";
		rule += "import erdf.poc.cep.*;\n";
		rule += "rule \"test\"\n";
		rule += "timer (cron:0/2 * * * * ?)\n";
		rule += "when\n";
		rule += "then\n";
		rule += "insert(\"test\"+System.currentTimeMillis());\n";
		rule += "end";
		addRule(session, rule);

		session.fireAllRules();
		Thread.sleep(2000);
		session.fireAllRules();
		
		final int facts = session.getFactHandles().size();
		Assert.assertTrue(facts>=1);
		session.dispose();

		Thread.sleep(2000);
		
		session = getSession(id);
		addRule(session, rule);
		session.fireAllRules();
		
		Assert.assertTrue(session.getFactHandles().size()>facts);
		session.dispose();
	}

	private KieSession getSession(Integer i) {
		final Environment env = KnowledgeBaseFactory.newEnvironment();
		EnvironmentBuilder envBuilder = new
KnowledgeSessionStorageEnvironmentBuilder(storage);
		env.set(EnvironmentName.TRANSACTION_MANAGER,
envBuilder.getTransactionManager());
		env.set(EnvironmentName.PERSISTENCE_CONTEXT_MANAGER,
envBuilder.getPersistenceContextManager());
		KieStoreServices storeS = KieServices.Factory.get().getStoreServices();
		final KieBase kieBase = KnowledgeBaseFactory.newKnowledgeBase();
		if (i != null) {
			return storeS.loadKieSession(i, kieBase, null, env);
		}
		return storeS.newKieSession(kieBase, null, env);
	}

	private static class SimpleKnowledgeSessionStorage implements
KnowledgeSessionStorage {

		public Map<Integer, SessionInfo> ksessions = new HashMap<Integer,
SessionInfo>();
		public Map<Long, WorkItemInfo> workItems = new HashMap<Long,
WorkItemInfo>();

		public SessionInfo findSessionInfo(Integer id) {
			return ksessions.get(id);
		}

		public void saveOrUpdate(SessionInfo storedObject) {
			ksessions.put(storedObject.getId(), storedObject);
		}

		public void saveOrUpdate(WorkItemInfo workItemInfo) {
			workItems.put(workItemInfo.getId(), workItemInfo);
		}

		public Long getNextWorkItemId() {
			return new Long(workItems.size() + 1);
		}

		public WorkItemInfo findWorkItemInfo(Long id) {
			return workItems.get(id);
		}

		public void remove(WorkItemInfo workItemInfo) {
			workItems.remove(workItemInfo.getId());
		}

		public Integer getNextStatefulKnowledgeSessionId() {
			return ksessions.size() + 1;
		}
	}
}

Any idea ?

Thanks for your help
Didier




--
View this message in context: http://drools.46999.n3.nabble.com/External-storage-and-timers-tp4024486.html
Sent from the Drools: User forum mailing list archive at Nabble.com.