Author: clebert.suconic(a)jboss.com
Date: 2010-10-20 17:09:02 -0400 (Wed, 20 Oct 2010)
New Revision: 9803
Modified:
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorImpl.java
Log:
tweak
Modified:
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorImpl.java
===================================================================
---
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorImpl.java 2010-10-20
20:50:34 UTC (rev 9802)
+++
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorImpl.java 2010-10-20
21:09:02 UTC (rev 9803)
@@ -125,7 +125,7 @@
if (position.getMessageNr() > 0)
{
- cursorInfo.confirmed.addAndGet(position.getMessageNr() - 1);
+ cursorInfo.confirmed.addAndGet(position.getMessageNr());
}
ack(position);
Show replies by date