[jboss-user] [jBPM] - jBPM5 and ObjectMarshallingStrategy

[Miljenko Norsic]

Miljenko Norsic [http://community.jboss.org/people/mnorsic] created the discussion

"jBPM5 and ObjectMarshallingStrategy"

To view the discussion, visit: http://community.jboss.org/message/631373#631373

--------------------------------------------------------------
Hi All,

I have a question about persistent JPA object marshalling strategies.
I'd like to use jBPM5 in an already built project that uses custom ORM mapper (something similar to Hibernate, but uses its own persistency mechanism).
Ideally, I'd love to use somethning similar to JPAPlaceholderResolverStrategy, to force jBPM5 to store only class name and its primary key.

So I've started to look into jBPM5 code to see where can I plug in my persistency mechanism, and found that I have to add my custom object marshaller into enviroment:
env.set(EnvironmentName.OBJECT_MARSHALLING_STRATEGIES, new ObjectMarshallingStrategy[] {
new MyCustomMarshallingStrategy(env),
 new JPAPlaceholderResolverStrategy(env),
 new SerializablePlaceholderResolverStrategy(ClassObjectMarshallingStrategyAcceptor.DEFAULT) });


So, now my custom resolver is used in marshalling and unmarshalling to write and read object reference into database, instead storing whole serialized object, and that seems OK.
But my custom Java objects do not implement Serializable, and I've spotted the following error:

java.lang.RuntimeException: Unable to get session snapshot
 at org.drools.persistence.SessionMarshallingHelper.getSnapshot(SessionMarshallingHelper.java:75)
 at org.drools.persistence.info.SessionInfo.update(SessionInfo.java:81)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
 at java.lang.reflect.Method.invoke(Method.java:597)
 at org.hibernate.ejb.event.BeanCallback.invoke(BeanCallback.java:23)
 at org.hibernate.ejb.event.EntityCallbackHandler.callback(EntityCallbackHandler.java:80)
 at org.hibernate.ejb.event.EntityCallbackHandler.preUpdate(EntityCallbackHandler.java:65)
 at org.hibernate.ejb.event.EJB3FlushEntityEventListener.invokeInterceptor(EJB3FlushEntityEventListener.java:41)
 at org.hibernate.event.def.DefaultFlushEntityEventListener.handleInterception(DefaultFlushEntityEventListener.java:330)
 at org.hibernate.event.def.DefaultFlushEntityEventListener.scheduleUpdate(DefaultFlushEntityEventListener.java:270)
 at org.hibernate.event.def.DefaultFlushEntityEventListener.onFlushEntity(DefaultFlushEntityEventListener.java:151)
 at org.hibernate.event.def.AbstractFlushingEventListener.flushEntities(AbstractFlushingEventListener.java:219)
 at org.hibernate.event.def.AbstractFlushingEventListener.flushEverythingToExecutions(AbstractFlushingEventListener.java:99)
 at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:49)
 at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1027)
 at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:365)
 at org.hibernate.ejb.AbstractEntityManagerImpl$1.beforeCompletion(AbstractEntityManagerImpl.java:504)
 ... 28 more
Caused by: java.io.NotSerializableException: hr.mnorsic.test.bo.SomeClass
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1164)
 at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:330)
 at java.util.HashMap.writeObject(HashMap.java:1001)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
 at java.lang.reflect.Method.invoke(Method.java:597)
 at java.io.ObjectStreamClass.invokeWriteObject(ObjectStreamClass.java:945)
 at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1469)
 at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1400)
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1158)
 at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1518)
 at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1483)
 at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1400)
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1158)
 at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:330)
 at java.util.ArrayList.writeObject(ArrayList.java:570)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
 at java.lang.reflect.Method.invoke(Method.java:597)
 at java.io.ObjectStreamClass.invokeWriteObject(ObjectStreamClass.java:945)
 at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1469)
at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1400)
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1158)
 at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1518)
 at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1483)
 at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1400)
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1158)
 at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:330)
 at org.drools.marshalling.impl.SerializablePlaceholderResolverStrategy.write(SerializablePlaceholderResolverStrategy.java:53)
 at org.drools.marshalling.impl.OutputMarshaller.writeFactHandle(OutputMarshaller.java:305)
 at org.drools.marshalling.impl.OutputMarshaller.writeFactHandle(OutputMarshaller.java:325)
 at org.drools.marshalling.impl.OutputMarshaller.writeFactHandles(OutputMarshaller.java:267)
 at org.drools.marshalling.impl.OutputMarshaller.writeSession(OutputMarshaller.java:107)
 at org.drools.marshalling.impl.DefaultMarshaller.marshall(DefaultMarshaller.java:136)
 at org.drools.persistence.SessionMarshallingHelper.getSnapshot(SessionMarshallingHelper.java:72)


My class (SomeClass) does not implement Serializable, but it seems weird that jBPM is trying to use SerializablePlaceholderResolverStrategy to store knowledge session info instead my own persistency strategy.
Digging down into jBPM5 code, I have found that RuleFlowProcessInstance object is serialized by using SerializablePlaceholderResolverStrategy, and that object contains VariableScopeInstance object (in a subContextInstances HashMap).
And VariableScopeInstance contains process instance variables, so they are serialized into a byte array instead using JPA strategy (or my own strategy, doesn't matter).
At the same time, process instance is stored correctly (it uses JPA resolver strategy and stores only a reference to an object stored in a database).

I think this is not correct, as process instance contains a reference to an object a database, and session info contains whole serialized objects?

Could please someone from jBPM team review my observation?
My guess is that when RuleFlowProcessInstance is persisted, subContextInstances Map should be examined, and for each element a query to a objectMarshallingStrategyStore accept() method should be called to determine the correct persistence strategy.

Thanks,
Miljenko

P.S. forgot to mention: my process contains rule task and custom tasks (controlled by custom work item handler).
--------------------------------------------------------------

Reply to this message by going to Community
[http://community.jboss.org/message/631373#631373]

Start a new discussion in jBPM at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2034]

-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/jboss-user/attachments/20111012/5ce06d10/attachment-0001.html