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

https://issues.apache.org/jira/browse/AMQ-3986 - optimizeDurablePrefetch on ActiveMQConnectionSupport 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1378057 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2012-08-28 10:17:58 +00:00
parent 9b0316b9b4
commit 00bdf0044a
2 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQConnectionRequestInfo.java
View File

@ -251,6 +251,10 @@ public class ActiveMQConnectionRequestInfo implements ConnectionRequestInfo, Ser
return Integer.valueOf(prefetchPolicy().getDurableTopicPrefetch());
}
public Integer getOptimizeDurableTopicPrefetch() {
return Integer.valueOf(prefetchPolicy().getOptimizeDurableTopicPrefetch());
}
public Integer getInputStreamPrefetch() {
return Integer.valueOf(prefetchPolicy().getInputStreamPrefetch());
}

17
activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQConnectionSupport.java
View File

@ -208,6 +208,23 @@ public class ActiveMQConnectionSupport {
return info.getDurableTopicPrefetch();
}
/**
* @param optimizeDurableTopicPrefetch
*/
public void setOptimizeDurableTopicPrefetch(Integer optimizeDurableTopicPrefetch) {
if ( log.isDebugEnabled() ) {
log.debug("setting [optimizeDurableTopicPrefetch] to: " + optimizeDurableTopicPrefetch);
}
info.setOptimizeDurableTopicPrefetch(optimizeDurableTopicPrefetch);
}
/**
* @return durable topic prefetch
*/
public Integer getOptimizeDurableTopicPrefetch() {
return info.getOptimizeDurableTopicPrefetch();
}
/**
* @param durableTopicPrefetch
*/