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

Enable optimized ack by default again but disable the broker from sending the prefetch resize command to the client.. the client still has not implemented proper thread safe handling for that. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399530 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-05-04 03:45:59 +00:00
parent 84bee771f8
commit c6e0984e1d
3 changed files with 5 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/ActiveMQConnectionFactory.java
View File

@ -82,7 +82,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
protected boolean asyncDispatch = false;
protected boolean alwaysSessionAsync=true;
private boolean useAsyncSend = false;
private boolean optimizeAcknowledge = false;
private boolean optimizeAcknowledge = true;
private int closeTimeout = 15000;
private boolean useRetroactiveConsumer;

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

@ -251,6 +251,7 @@ abstract public class PrefetchSubscription extends AbstractSubscription{
*
*/
public void optimizePrefetch(){
/*
if(info!=null&&info.isOptimizedAcknowledge()&&context!=null&&context.getConnection()!=null
&&context.getConnection().isManageable()){
if(info.getCurrentPrefetchSize()!=info.getPrefetchSize() && isLowWaterMark()){
@ -262,6 +263,7 @@ abstract public class PrefetchSubscription extends AbstractSubscription{
updateConsumerPrefetch(1);
}
}
*/
}

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

@ -271,6 +271,7 @@ public class TopicSubscription extends AbstractSubscription{
*
*/
public void optimizePrefetch(){
/*
if(info!=null&&info.isOptimizedAcknowledge()&&context!=null&&context.getConnection()!=null
&&context.getConnection().isManageable()){
if(info.getCurrentPrefetchSize()!=info.getPrefetchSize() && isLowWaterMark()){
@ -282,6 +283,7 @@ public class TopicSubscription extends AbstractSubscription{
updateConsumerPrefetch(1);
}
}
*/
}
private void dispatchMatched() throws IOException{