Browse files

tweak on my last fix to fix BasicXATest

  • Loading branch information...
1 parent 7391970 commit fd2e3085a6f843ea9d2a890b04e4b246b9da3788 @clebertsuconic clebertsuconic committed Dec 6, 2009
Showing with 9 additions and 8 deletions.
  1. +9 −8 src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java
View
17 src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java
@@ -949,14 +949,6 @@ private boolean onDepage(final int pageId, final SimpleString destination, final
final long transactionIdDuringPaging = pagedMessage.getTransactionID();
- postOffice.route(message, depageTransaction);
-
- // This means the page is duplicated. So we need to ignore this
- if (depageTransaction.getState() == State.ROLLBACK_ONLY)
- {
- break;
- }
-
PageTransactionInfo pageUserTransaction = null;
if (transactionIdDuringPaging >= 0)
@@ -1003,6 +995,15 @@ private boolean onDepage(final int pageId, final SimpleString destination, final
}
+ postOffice.route(message, depageTransaction);
+
+ // This means the page is duplicated. So we need to ignore this
+ if (depageTransaction.getState() == State.ROLLBACK_ONLY)
+ {
+ break;
+ }
+
+
// Update information about transactions
// This needs to be done after routing because of duplication detection
if (pageUserTransaction != null && message.isDurable())

0 comments on commit fd2e308

Please sign in to comment.