org.drools.marshalling.impl
Class ProtobufInputMarshaller

java.lang.Object
  extended by org.drools.marshalling.impl.ProtobufInputMarshaller

public class ProtobufInputMarshaller
extends Object

An input marshaller that uses protobuf.


Nested Class Summary
static class ProtobufInputMarshaller.ActivationKey
           
static class ProtobufInputMarshaller.PBActivationsFilter
           
static class ProtobufInputMarshaller.QueryElementContext
           
static class ProtobufInputMarshaller.TupleKey
           
 
Constructor Summary
ProtobufInputMarshaller()
           
 
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
 

Constructor Detail

ProtobufInputMarshaller

public ProtobufInputMarshaller()
Method Detail

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.