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

tidied up code a little 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@366153 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-01-05 10:51:12 +00:00
parent 205ac1188a
commit f73e2097dd
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnectionFactory.java
View File

@ -177,6 +177,11 @@ public class ActiveMQManagedConnectionFactory implements ManagedConnectionFactor
info.setUseInboundSession(useInboundSession); info.setUseInboundSession(useInboundSession);
} }
public boolean isUseInboundSessionEnabled() {
return info.isUseInboundSessionEnabled();
}
// Redelivery policy configuration
public Long getInitialRedeliveryDelay() { public Long getInitialRedeliveryDelay() {
return info.getInitialRedeliveryDelay(); return info.getInitialRedeliveryDelay();
} }
@ -193,10 +198,6 @@ public class ActiveMQManagedConnectionFactory implements ManagedConnectionFactor
return info.getRedeliveryUseExponentialBackOff(); return info.getRedeliveryUseExponentialBackOff();
} }
public boolean isUseInboundSessionEnabled() {
return info.isUseInboundSessionEnabled();
}
public void setInitialRedeliveryDelay(Long value) { public void setInitialRedeliveryDelay(Long value) {
info.setInitialRedeliveryDelay(value); info.setInitialRedeliveryDelay(value);
} }
@ -209,6 +210,12 @@ public class ActiveMQManagedConnectionFactory implements ManagedConnectionFactor
info.setRedeliveryBackOffMultiplier(value); info.setRedeliveryBackOffMultiplier(value);
} }
public void setRedeliveryUseExponentialBackOff(Boolean value) {
info.setRedeliveryUseExponentialBackOff(value);
}
// Prefetch policy configuration
public Integer getDurableTopicPrefetch() { public Integer getDurableTopicPrefetch() {
return info.getDurableTopicPrefetch(); return info.getDurableTopicPrefetch();
} }
@ -249,10 +256,6 @@ public class ActiveMQManagedConnectionFactory implements ManagedConnectionFactor
info.setQueuePrefetch(queuePrefetch); info.setQueuePrefetch(queuePrefetch);
} }
public void setRedeliveryUseExponentialBackOff(Boolean value) {
info.setRedeliveryUseExponentialBackOff(value);
}
public void setTopicPrefetch(Integer topicPrefetch) { public void setTopicPrefetch(Integer topicPrefetch) {
info.setTopicPrefetch(topicPrefetch); info.setTopicPrefetch(topicPrefetch);
} }