Author: jmesnil
Date: 2010-07-15 08:43:50 -0400 (Thu, 15 Jul 2010)
New Revision: 9402
Modified:
trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java
Log:
PagingStore.isPaging() always returns false if the policy is to BLOCK
Modified: trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java 2010-07-15 10:21:14
UTC (rev 9401)
+++ trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java 2010-07-15 12:43:50
UTC (rev 9402)
@@ -220,8 +220,12 @@
try
{
- if (addressFullMessagePolicy != AddressFullMessagePolicy.PAGE)
+ if (addressFullMessagePolicy == AddressFullMessagePolicy.BLOCK)
{
+ return false;
+ }
+ else if (addressFullMessagePolicy == AddressFullMessagePolicy.DROP)
+ {
return isFull();
}
else
Show replies by date