Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Apply fix for https://issues.apache.org/activemq/browse/AMQ-1935 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@694781 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-09-12 19:24:55 +00:00
parent 47130408a7
commit f2fc86405f
3 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
View File

@ -41,7 +41,7 @@ public class AbstractPendingMessageCursor implements PendingMessageCursor {
protected int maxAuditDepth=1000;
protected boolean enableAudit=true;
protected ActiveMQMessageAudit audit;
protected boolean useCache=false;
protected boolean useCache=true;
private boolean started=false;

1
activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
View File

@ -65,6 +65,7 @@ public class FilePendingMessageCursor extends AbstractPendingMessageCursor imple
* @param store
*/
public FilePendingMessageCursor(Broker broker,String name) {
this.useCache=false;
this.broker = broker;
//the store can be null if the BrokerService has persistence
//turned off

4
activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
View File

@ -37,6 +37,10 @@ public class VMPendingMessageCursor extends AbstractPendingMessageCursor {
private Iterator<MessageReference> iter;
private MessageReference last;
public VMPendingMessageCursor(){
this.useCache=false;
}
@Override
public List<MessageReference> remove(ConnectionContext context, Destination destination) throws Exception {