org.drools.marshalling.impl
Class ProtobufInputMarshaller
java.lang.Object
org.drools.marshalling.impl.ProtobufInputMarshaller
public class ProtobufInputMarshaller
- extends Object
An input marshaller that uses protobuf.
Method Summary |
static void |
readActionQueue(MarshallerReaderContext context,
ProtobufMessages.RuleData _session)
|
static void |
readAgenda(MarshallerReaderContext context,
ProtobufMessages.RuleData _ruleData,
DefaultAgenda agenda)
|
static InternalFactHandle |
readFactHandle(MarshallerReaderContext context,
org.drools.runtime.rule.WorkingMemoryEntryPoint entryPoint,
ProtobufMessages.FactHandle _handle)
|
static void |
readFactHandles(MarshallerReaderContext context,
ProtobufMessages.EntryPoint _ep,
ObjectStore objectStore)
|
static ReteooStatefulSession |
readSession(MarshallerReaderContext context,
int id,
ExecutorService executor)
Create a new session into which to read the stream data |
static ReteooStatefulSession |
readSession(MarshallerReaderContext context,
int id,
ExecutorService executor,
org.drools.runtime.Environment environment,
SessionConfiguration config)
|
static ReteooStatefulSession |
readSession(ProtobufMessages.KnowledgeSession _session,
ReteooStatefulSession session,
DefaultAgenda agenda,
MarshallerReaderContext context)
|
static ReteooStatefulSession |
readSession(ReteooStatefulSession session,
MarshallerReaderContext context)
Stream the data into an existing session |
static void |
readTimer(MarshallerReaderContext inCtx,
ProtobufMessages.Timers.Timer _timer)
|
static Trigger |
readTrigger(MarshallerReaderContext inCtx,
ProtobufMessages.Trigger _trigger)
|
static void |
readTruthMaintenanceSystem(MarshallerReaderContext context,
ProtobufMessages.RuleData _session)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ProtobufInputMarshaller
public ProtobufInputMarshaller()
readSession
public static ReteooStatefulSession readSession(ReteooStatefulSession session,
MarshallerReaderContext context)
throws IOException,
ClassNotFoundException
- Stream the data into an existing session
- Parameters:
session
- context
- id
- executor
-
- Returns:
-
- Throws:
IOException
ClassNotFoundException
readSession
public static ReteooStatefulSession readSession(MarshallerReaderContext context,
int id,
ExecutorService executor)
throws IOException,
ClassNotFoundException
- Create a new session into which to read the stream data
- Parameters:
context
- id
- executor
-
- Returns:
-
- Throws:
IOException
ClassNotFoundException
readSession
public static ReteooStatefulSession readSession(MarshallerReaderContext context,
int id,
ExecutorService executor,
org.drools.runtime.Environment environment,
SessionConfiguration config)
throws IOException,
ClassNotFoundException
- Throws:
IOException
ClassNotFoundException
readSession
public static ReteooStatefulSession readSession(ProtobufMessages.KnowledgeSession _session,
ReteooStatefulSession session,
DefaultAgenda agenda,
MarshallerReaderContext context)
throws IOException,
ClassNotFoundException
- Throws:
IOException
ClassNotFoundException
readAgenda
public static void readAgenda(MarshallerReaderContext context,
ProtobufMessages.RuleData _ruleData,
DefaultAgenda agenda)
readActionQueue
public static void readActionQueue(MarshallerReaderContext context,
ProtobufMessages.RuleData _session)
throws IOException,
ClassNotFoundException
- Throws:
IOException
ClassNotFoundException
readFactHandles
public static void readFactHandles(MarshallerReaderContext context,
ProtobufMessages.EntryPoint _ep,
ObjectStore objectStore)
throws IOException,
ClassNotFoundException
- Throws:
IOException
ClassNotFoundException
readFactHandle
public static InternalFactHandle readFactHandle(MarshallerReaderContext context,
org.drools.runtime.rule.WorkingMemoryEntryPoint entryPoint,
ProtobufMessages.FactHandle _handle)
throws IOException,
ClassNotFoundException
- Throws:
IOException
ClassNotFoundException
readTruthMaintenanceSystem
public static void readTruthMaintenanceSystem(MarshallerReaderContext context,
ProtobufMessages.RuleData _session)
throws IOException
- Throws:
IOException
readTimer
public static void readTimer(MarshallerReaderContext inCtx,
ProtobufMessages.Timers.Timer _timer)
throws IOException,
ClassNotFoundException
- Throws:
IOException
ClassNotFoundException
readTrigger
public static Trigger readTrigger(MarshallerReaderContext inCtx,
ProtobufMessages.Trigger _trigger)
Copyright © 2001-2012 JBoss by Red Hat. All Rights Reserved.