List of generateSequenceNumber() Examples

Examples of generateSequenceNumber()

com.sun.messaging.jmq.io.GPacket.generateSequenceNumber()
Disable (and enable) sequence number generation. The GPacket specification defines a "sequence number" field that is defined to be a monotonically increasing sequence number. By default GPacket will automatically increment the sequence number and set it on the packet every time writePacket() is called. The sequence number is a class variable so all packets in a VM share the same sequence. @param generate true to have the packetautomatically generate sequence numbers for you, false to not. Default is true.
com.sun.messaging.jmq.io.Packet.generateSequenceNumber()
Disable (and enable) sequence number generation. The JMQ packet specification defines a "sequence number" field that is defined to be an increasing sequence number. By default Packet will automatically increment the sequence number and set it on the packet every time writePacket() is called. The sequence number is a class variable so all packets in a VM share the same sequence. @param generate true to have the packet automatically generatesequence numbers for you, false to not. Default is "true".

Examples of com.sun.messaging.jmq.io.GPacket.generateSequenceNumber()

        return new HeartbeatInfo(pkt);
    }


    public GPacket getGPacket() {
        GPacket gp = GPacket.getInstance();
        gp.generateSequenceNumber(false);
        gp.setType(HEARTBEAT_ALIVE);
        gp.setSequence(sequence);
        gp.putProp("protocolVersion", new Integer(HEARTBEAT_PROTOCOL_VERSION));
        gp.putProp("brokerID", brokerID);
        gp.putProp("brokerSession", new Long(brokerSession));

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()

            if (roPkt == null) {
                throw new BrokerException(Globals.getBrokerResources().getKString(
                          BrokerResources.X_NULL_PACKET_FROM_REF, ref.toString()));
            }
            roPkt.generateTimestamp(false);
            roPkt.generateSequenceNumber(false);


            roPkt.writePacket(dos);
            dos.flush();
            bos.flush();

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()

        assert ( pkt !=  null );
        assert ( dis !=  null );


        Packet roPkt = new Packet(false);
        roPkt.generateTimestamp(false);
        roPkt.generateSequenceNumber(false);
        roPkt.readPacket(dis);
        return roPkt;
    }


    public boolean needReply() {

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()

        // queue ... if we dont, an exception will be thrown
        // from queue Message
        boolean route = false;
        PacketReference ref = null;
        try {
            newp.generateSequenceNumber(false);
            newp.generateTimestamp(false);
            newp.fill(p);
            newp.setProperties(props);


            if (truncateBody) {

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()

        int msgCount = dis.readInt(); // Number of msgs to process
        for (int i = 0; i < msgCount; i++) {
            // Reconstruct the message
            Packet pkt = new Packet(false);
            pkt.generateTimestamp(false);
            pkt.generateSequenceNumber(false);
            pkt.readPacket(dis);


            SysMessageID mid = pkt.getSysMessageID();


            // Make sure dst exists; autocreate if possible

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()


  ByteBuffer databuf = ByteBuffer.wrap(data);
  JMQByteBufferInputStream bis = new JMQByteBufferInputStream(databuf);
  Packet msg = new Packet(false);
        msg.generateTimestamp(false);
        msg.generateSequenceNumber(false);
  msg.readPacket(bis);
  bis.close();
  return msg;
    }

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()


      packetSize = r.readInt();


      Packet pkt = new Packet();
      pkt.generateTimestamp(false);
      pkt.generateSequenceNumber(false);


      // parse message
      if (parent.useFileChannel) {
    pkt.readPacket(r.getChannel(), false);
      } else {

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()

      while (rs.next()) {
                oldMsgID = rs.getString(1);


    msg = new Packet(false);
    msg.generateTimestamp(false);
    msg.generateSequenceNumber(false);
    InputStream is = useBlob ?
                    rs.getBlob(2).getBinaryStream() : rs.getBinaryStream(2);
    msg.readPacket(is);
    is.close();

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()

        }


        while ( rs.next() ) {
            Packet msg = new Packet(false);
            msg.generateTimestamp(false);
            msg.generateSequenceNumber(false);


            InputStream is = null;
            if ( getMsgColumnType(rs, 1) == Types.BLOB ) {
                Blob blob = rs.getBlob( 1 );
                is = blob.getBinaryStream();

View Full Code Here

Examples of com.sun.messaging.jmq.io.Packet.generateSequenceNumber()

      while (rs.next()) {
                msgID = rs.getString(1);


    msg = new Packet(false);
    msg.generateTimestamp(false);
    msg.generateSequenceNumber(false);
                InputStream is = null;
                Blob blob = rs.getBlob(2);
                is = blob.getBinaryStream();
    msg.readPacket(is);
    is.close();

View Full Code Here

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.