public class MarshallerReaderContext extends ObjectInputStream
ObjectInputStream.GetField
baseWireHandle, PROTOCOL_VERSION_1, PROTOCOL_VERSION_2, SC_BLOCK_DATA, SC_ENUM, SC_EXTERNALIZABLE, SC_SERIALIZABLE, SC_WRITE_METHOD, STREAM_MAGIC, STREAM_VERSION, SUBCLASS_IMPLEMENTATION_PERMISSION, SUBSTITUTION_PERMISSION, TC_ARRAY, TC_BASE, TC_BLOCKDATA, TC_BLOCKDATALONG, TC_CLASS, TC_CLASSDESC, TC_ENDBLOCKDATA, TC_ENUM, TC_EXCEPTION, TC_LONGSTRING, TC_MAX, TC_NULL, TC_OBJECT, TC_PROXYCLASSDESC, TC_REFERENCE, TC_RESET, TC_STRING
Constructor and Description |
---|
MarshallerReaderContext(InputStream stream,
InternalKnowledgeBase kBase,
Map<Integer,BaseNode> sinks,
org.kie.api.marshalling.ObjectMarshallingStrategyStore resolverStrategyFactory,
Map<Integer,TimersInputMarshaller> timerReaders,
boolean marshalProcessInstances,
boolean marshalWorkItems,
org.kie.api.runtime.Environment env) |
MarshallerReaderContext(InputStream stream,
InternalKnowledgeBase kBase,
Map<Integer,BaseNode> sinks,
org.kie.api.marshalling.ObjectMarshallingStrategyStore resolverStrategyFactory,
Map<Integer,TimersInputMarshaller> timerReaders,
org.kie.api.runtime.Environment env) |
Modifier and Type | Method and Description |
---|---|
void |
addTimerNodeScheduler(int nodeId,
ProtobufInputMarshaller.TupleKey key,
PhreakTimerNode.Scheduler scheduler) |
PhreakTimerNode.Scheduler |
removeTimerNodeScheduler(int nodeId,
ProtobufInputMarshaller.TupleKey key) |
protected Class<?> |
resolveClass(ObjectStreamClass desc) |
available, close, defaultReadObject, enableResolveObject, read, read, readBoolean, readByte, readChar, readClassDescriptor, readDouble, readFields, readFloat, readFully, readFully, readInt, readLine, readLong, readObject, readObjectOverride, readShort, readStreamHeader, readUnshared, readUnsignedByte, readUnsignedShort, readUTF, registerValidation, resolveObject, resolveProxyClass, skipBytes
mark, markSupported, read, reset, skip
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
read, skip
public final MarshallerReaderContext stream
public final InternalKnowledgeBase kBase
public InternalWorkingMemory wm
public org.kie.internal.runtime.KnowledgeRuntime kruntime
public Map<Integer,InternalFactHandle> handles
public final Map<RightTupleKey,RightTuple> rightTuples
public final ProtobufInputMarshaller.PBActivationsFilter filter
public final org.kie.api.marshalling.ObjectMarshallingStrategyStore resolverStrategyFactory
public final Map<Integer,org.kie.api.marshalling.ObjectMarshallingStrategy> usedStrategies
public final Map<org.kie.api.marshalling.ObjectMarshallingStrategy,org.kie.api.marshalling.ObjectMarshallingStrategy.Context> strategyContexts
public final Map<String,EntryPointId> entryPoints
public final Map<Integer,TimersInputMarshaller> readersByInt
public final Map<Long,PropagationContext> propagationContexts
public final boolean marshalProcessInstances
public final boolean marshalWorkItems
public final org.kie.api.runtime.Environment env
public Object parameterObject
public ClassLoader classLoader
public Map<Integer,Map<ProtobufInputMarshaller.TupleKey,PhreakTimerNode.Scheduler>> timerNodeSchedulers
public MarshallerReaderContext(InputStream stream, InternalKnowledgeBase kBase, Map<Integer,BaseNode> sinks, org.kie.api.marshalling.ObjectMarshallingStrategyStore resolverStrategyFactory, Map<Integer,TimersInputMarshaller> timerReaders, org.kie.api.runtime.Environment env) throws IOException
IOException
public MarshallerReaderContext(InputStream stream, InternalKnowledgeBase kBase, Map<Integer,BaseNode> sinks, org.kie.api.marshalling.ObjectMarshallingStrategyStore resolverStrategyFactory, Map<Integer,TimersInputMarshaller> timerReaders, boolean marshalProcessInstances, boolean marshalWorkItems, org.kie.api.runtime.Environment env) throws IOException
IOException
protected Class<?> resolveClass(ObjectStreamClass desc) throws IOException, ClassNotFoundException
resolveClass
in class ObjectInputStream
IOException
ClassNotFoundException
public void addTimerNodeScheduler(int nodeId, ProtobufInputMarshaller.TupleKey key, PhreakTimerNode.Scheduler scheduler)
public PhreakTimerNode.Scheduler removeTimerNodeScheduler(int nodeId, ProtobufInputMarshaller.TupleKey key)
Copyright © 2001–2015 JBoss by Red Hat. All rights reserved.