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. _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users