org.drools.marshalling.impl
Class PersisterHelper

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

public class PersisterHelper
extends Object


Constructor Summary
PersisterHelper()
           
 
Method Summary
static com.google.protobuf.ExtensionRegistry buildRegistry(MarshallerReaderContext context, ProcessMarshaller processMarshaller)
           
static int byteArrayToInt(byte[] b)
           
static long byteArrayToLong(byte[] b)
           
static ProtobufMessages.Activation createActivation(String packageName, String ruleName, LeftTuple tuple)
           
static ProtobufInputMarshaller.ActivationKey createActivationKey(String pkgName, String ruleName, LeftTuple leftTuple)
           
static ProtobufInputMarshaller.ActivationKey createActivationKey(String pkgName, String ruleName, ProtobufMessages.Tuple _tuple)
           
static ProtobufMessages.Tuple createTuple(LeftTuple leftTuple)
           
static int[] createTupleArray(LeftTuple leftTuple)
           
static int[] createTupleArray(ProtobufMessages.Tuple _tuple)
           
static ProtobufInputMarshaller.TupleKey createTupleKey(LeftTuple leftTuple)
           
static ProtobufInputMarshaller.TupleKey createTupleKey(ProtobufMessages.Tuple _tuple)
           
static WorkingMemoryAction deserializeWorkingMemoryAction(MarshallerReaderContext context, ProtobufMessages.ActionQueue.Action _action)
           
static byte[] intToByteArray(int value)
           
static byte[] longToByteArray(long value)
           
static ProtobufMessages.Header readFromStreamWithHeader(MarshallerReaderContext context, com.google.protobuf.ExtensionRegistry registry)
           
static WorkingMemoryAction readWorkingMemoryAction(MarshallerReaderContext context)
           
 void write(MarshallerWriteContext context)
           
static void writeToStreamWithHeader(MarshallerWriteContext context, com.google.protobuf.Message payload)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PersisterHelper

public PersisterHelper()
Method Detail

readWorkingMemoryAction

public static WorkingMemoryAction readWorkingMemoryAction(MarshallerReaderContext context)
                                                   throws IOException,
                                                          ClassNotFoundException
Throws:
IOException
ClassNotFoundException

deserializeWorkingMemoryAction

public static WorkingMemoryAction deserializeWorkingMemoryAction(MarshallerReaderContext context,
                                                                 ProtobufMessages.ActionQueue.Action _action)
                                                          throws IOException,
                                                                 ClassNotFoundException
Throws:
IOException
ClassNotFoundException

write

public void write(MarshallerWriteContext context)
           throws IOException
Throws:
IOException

createActivationKey

public static ProtobufInputMarshaller.ActivationKey createActivationKey(String pkgName,
                                                                        String ruleName,
                                                                        ProtobufMessages.Tuple _tuple)

createActivationKey

public static ProtobufInputMarshaller.ActivationKey createActivationKey(String pkgName,
                                                                        String ruleName,
                                                                        LeftTuple leftTuple)

createTuple

public static ProtobufMessages.Tuple createTuple(LeftTuple leftTuple)

createTupleArray

public static int[] createTupleArray(ProtobufMessages.Tuple _tuple)

createTupleArray

public static int[] createTupleArray(LeftTuple leftTuple)

createTupleKey

public static ProtobufInputMarshaller.TupleKey createTupleKey(ProtobufMessages.Tuple _tuple)

createTupleKey

public static ProtobufInputMarshaller.TupleKey createTupleKey(LeftTuple leftTuple)

createActivation

public static ProtobufMessages.Activation createActivation(String packageName,
                                                           String ruleName,
                                                           LeftTuple tuple)

writeToStreamWithHeader

public static void writeToStreamWithHeader(MarshallerWriteContext context,
                                           com.google.protobuf.Message payload)
                                    throws IOException
Throws:
IOException

readFromStreamWithHeader

public static ProtobufMessages.Header readFromStreamWithHeader(MarshallerReaderContext context,
                                                               com.google.protobuf.ExtensionRegistry registry)
                                                        throws IOException,
                                                               ClassNotFoundException
Throws:
IOException
ClassNotFoundException

buildRegistry

public static com.google.protobuf.ExtensionRegistry buildRegistry(MarshallerReaderContext context,
                                                                  ProcessMarshaller processMarshaller)

intToByteArray

public static final byte[] intToByteArray(int value)

byteArrayToInt

public static final int byteArrayToInt(byte[] b)

longToByteArray

public static final byte[] longToByteArray(long value)

byteArrayToLong

public static final long byteArrayToLong(byte[] b)


Copyright © 2001-2012 JBoss by Red Hat. All Rights Reserved.