Examples of addRange()


Examples of org.apache.sandesha2.util.RangeString.addRange()

    RangeString rString = new RangeString(msgs);
   
    //msg 2 arrives
    {
      Range ackedMsgRange = new Range(1,2);
      Range[] newRanges = rString.addRange(ackedMsgRange).getRanges();
      assertEquals(newRanges.length,1);
      assertEquals(newRanges[0],new Range(2,2));
    }
   
    //msgs 8 and 9 arrive
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

    }
   
    //msgs 8 and 9 arrive
    {
      Range ackedMsgRange = new Range(8,9);
      Range[] newRanges = rString.addRange(ackedMsgRange).getRanges();
      assertEquals(newRanges.length,1);
      assertEquals(newRanges[0],ackedMsgRange);
    }
   
    // msg 6 arrives
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

    }
   
    // msg 6 arrives
    {
      Range ackedMsgRange = new Range(6,6);
      Range[] newRanges = rString.addRange(ackedMsgRange).getRanges();
      assertEquals(newRanges.length,1);
      assertEquals(newRanges[0],ackedMsgRange);
    }
   
    //msgs 3,4 and 5 arrive
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

    }
   
    //msgs 3,4 and 5 arrive
    {
      Range ackedMsgRange = new Range(1,5);
      Range[] newRanges = rString.addRange(ackedMsgRange).getRanges();
      assertEquals(newRanges.length,1);
      assertEquals(newRanges[0],new Range(3,5));
    }
   
    //msgs 3,4 are duplicated
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

    }
   
    //msgs 3,4 are duplicated
    {
      Range ackedMsgRange = new Range(3,4);
      Range[] newRanges = rString.addRange(ackedMsgRange).getRanges();
      assertEquals(newRanges.length,0); //no new information
    }
   
    //finally msg 7
    {
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

    }
   
    //finally msg 7
    {
      Range ackedMsgRange = new Range(7,7);
      Range[] newRanges = rString.addRange(ackedMsgRange).getRanges();
      assertEquals(newRanges.length,1);
      assertEquals(newRanges[0],ackedMsgRange);
    }
   
    //all msgs have now arrived
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

   
    //all msgs have now arrived
    assertEquals("[1,10]", rString.toString());
   
    //all messages are duplicated - ensure this is detected
    assertEquals(rString.addRange(new Range(1,10)).getRanges().length, 0)
    //check we handle duplicates i.e. the string is still correct
    assertEquals("[1,10]", rString.toString());
  }
 
  public void testSerialize()throws Exception{
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

    // Updating the server completed message ranges list
    RangeString serverCompletedMessageRanges = bean.getServerCompletedMessages();
    // See if the message is in the list of completed ranges
    boolean msgNoPresentInList =  serverCompletedMessageRanges.isMessageNumberInRanges(msgNo);
    if (!msgNoPresentInList){
       serverCompletedMessageRanges.addRange(new Range(msgNo));
    }

    // updating the Highest_In_Msg_No property which gives the highest
    // message number retrieved from this sequence.
    long highestInMsgNo = bean.getHighestInMessageNumber();
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

      Range ackedRange = new Range(lower, upper);
      // Quick check to see if the whole range is already covered
      if(!completedMessages.isRangeCompleted(ackedRange)) {
        //we now know that this range is complete so we update it. This should aggregate the
        //ranges together and tell us which numbers are newly acked
        Range[] newRanges = completedMessages.addRange(ackedRange).getRanges();

        // We now take each newly acked message in turn and see if we need to update a sender bean
        for (int rangeIndex=0; rangeIndex < newRanges.length; rangeIndex++) {
          //now work on each newly acked message in this range
          for(long messageNo = newRanges[rangeIndex].lowerValue; messageNo<=newRanges[rangeIndex].upperValue; messageNo++){
View Full Code Here

Examples of org.apache.sandesha2.util.RangeString.addRange()

  }
 
  public void testGetAckRangesFromRangeStringOutOfOrder() {
   
    RangeString rangeString = new RangeString();
    rangeString.addRange(new Range(3));
    rangeString.addRange(new Range(6));
    rangeString.addRange(new Range(1));
    rangeString.addRange(new Range(5));
    rangeString.addRange(new Range(8));
    rangeString.addRange(new Range(2));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.