Examples of java.io.ObjectOutputStream.writeLong()

java.io.ObjectOutputStream.writeLong()
Write primitive data of type long (value)into the receiver's underlying stream. @param value The primitive data to write @throws IOException If an IO exception happened when writing the primitive data.

                                base,
                                1024));
                }


                if (webConfig.isSet(WebContextInitParameter.ClientStateTimeout)) {
                    oos.writeLong(System.currentTimeMillis());
                }
                //noinspection NonSerializableObjectPassedToObjectStream
                oos.writeObject(view.getStructure());
                //noinspection NonSerializableObjectPassedToObjectStream
                oos.writeObject(view.getState());

View Full Code Here

  public void writeProcessInstance(MarshallerWriteContext context,
      ProcessInstance processInstance) throws IOException {


    WorkflowProcessInstanceImpl workFlow = (WorkflowProcessInstanceImpl) processInstance;
    ObjectOutputStream stream = context.stream;
    stream.writeLong(workFlow.getId());
    stream.writeUTF(workFlow.getProcessId());
    stream.writeInt(workFlow.getState());
    stream.writeLong(workFlow.getNodeInstanceCounter());
    
    VariableScopeInstance variableScopeInstance = (VariableScopeInstance) workFlow.getContextInstance( VariableScope.VARIABLE_SCOPE );

View Full Code Here

    WorkflowProcessInstanceImpl workFlow = (WorkflowProcessInstanceImpl) processInstance;
    ObjectOutputStream stream = context.stream;
    stream.writeLong(workFlow.getId());
    stream.writeUTF(workFlow.getProcessId());
    stream.writeInt(workFlow.getState());
    stream.writeLong(workFlow.getNodeInstanceCounter());
    
    VariableScopeInstance variableScopeInstance = (VariableScopeInstance) workFlow.getContextInstance( VariableScope.VARIABLE_SCOPE );
        Map<String, Object> variables = variableScopeInstance.getVariables();
        List<String> keys = new ArrayList<String>( variables.keySet() );
        Collections.sort( keys,

View Full Code Here

  }


  public void writeNodeInstance(MarshallerWriteContext context,
      NodeInstance nodeInstance) throws IOException {
    ObjectOutputStream stream = context.stream;
    stream.writeLong(nodeInstance.getId());
    stream.writeLong(nodeInstance.getNodeId());
    writeNodeInstanceContent(stream, nodeInstance, context);
  }


  protected void writeNodeInstanceContent(ObjectOutputStream stream,

View Full Code Here


  public void writeNodeInstance(MarshallerWriteContext context,
      NodeInstance nodeInstance) throws IOException {
    ObjectOutputStream stream = context.stream;
    stream.writeLong(nodeInstance.getId());
    stream.writeLong(nodeInstance.getNodeId());
    writeNodeInstanceContent(stream, nodeInstance, context);
  }


  protected void writeNodeInstanceContent(ObjectOutputStream stream,
      NodeInstance nodeInstance, MarshallerWriteContext context)

View Full Code Here

                ObjectHashMap memory = (ObjectHashMap) context.wm.getNodeMemory( (NodeMemory) sink );
                InternalFactHandle ifh = (InternalFactHandle) memory.get( leftTuple );
                // first we serialize the generated fact handle ID
//                context.out.println( "FactHandle id:"+ifh.getId() );
                stream.writeInt( ifh.getId() );
                stream.writeLong( ifh.getRecency() );
                
                writeRightTuples( ifh, context );


                stream.writeShort( PersisterEnums.END );
//                context.out.println( "RightInputAdapterNode   ---   END" );

View Full Code Here

                                       LeftTuple leftTuple,
                                       AgendaItem agendaItem,
                                       RuleTerminalNode ruleTerminalNode) throws IOException {
        ObjectOutputStream stream = context.stream;


        stream.writeLong( agendaItem.getActivationNumber() );


        stream.writeInt( context.terminalTupleMap.get( leftTuple ) );


        stream.writeInt( agendaItem.getSalience() );

View Full Code Here

        stream.writeUTF( rule.getName() );


//        context.out.println( "Rule " + rule.getPackage() + "." + rule.getName() );


//        context.out.println( "AgendaItem long:" + agendaItem.getPropagationContext().getPropagationNumber() );
        stream.writeLong( agendaItem.getPropagationContext().getPropagationNumber() );


        if ( agendaItem.getActivationGroupNode() != null ) {
            stream.writeBoolean( true );
//            context.out.println( "ActivationGroup bool:" + true );
            stream.writeUTF( agendaItem.getActivationGroupNode().getActivationGroup().getName() );

View Full Code Here

            stream.writeInt( tuples.get( tupleOrigin ) );
        } else {
            stream.writeBoolean( false );
        }


        stream.writeLong( pc.getPropagationNumber() );
        if ( pc.getFactHandleOrigin() != null ) {
            stream.writeInt( ((InternalFactHandle)pc.getFactHandleOrigin()).getId() );
        } else {
            stream.writeInt( -1 );
        }

View Full Code Here

    }


    public static void writeProcessInstance(MarshallerWriteContext context,
                                            RuleFlowProcessInstance processInstance) throws IOException {
        ObjectOutputStream stream = context.stream;
        stream.writeLong( processInstance.getId() );
        stream.writeUTF( processInstance.getProcessId() );
        stream.writeInt( processInstance.getState() );
        stream.writeLong( processInstance.getNodeInstanceCounter() );


        VariableScopeInstance variableScopeInstance = (VariableScopeInstance) processInstance.getContextInstance( VariableScope.VARIABLE_SCOPE );

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.