You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/04/03 01:26:19 UTC
svn commit: r1463791 - in
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core:
PrefetchPolicy.cpp RedeliveryPolicy.cpp
Author: tabish
Date: Tue Apr 2 23:26:19 2013
New Revision: 1463791
URL: http://svn.apache.org/r1463791
Log:
make uri options more closely match the Java client.
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/PrefetchPolicy.cpp
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/RedeliveryPolicy.cpp
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/PrefetchPolicy.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/PrefetchPolicy.cpp?rev=1463791&r1=1463790&r2=1463791&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/PrefetchPolicy.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/PrefetchPolicy.cpp Tue Apr 2 23:26:19 2013
@@ -37,25 +37,25 @@ void PrefetchPolicy::configure(const dec
try {
- if (properties.hasProperty("cms.PrefetchPolicy.durableTopicPrefetch")) {
+ if (properties.hasProperty("cms.prefetchPolicy.durableTopicPrefetch")) {
this->setDurableTopicPrefetch(Integer::parseInt(
- properties.getProperty("cms.PrefetchPolicy.durableTopicPrefetch")));
+ properties.getProperty("cms.prefetchPolicy.durableTopicPrefetch")));
}
- if (properties.hasProperty("cms.PrefetchPolicy.queueBrowserPrefetch")) {
+ if (properties.hasProperty("cms.prefetchPolicy.queueBrowserPrefetch")) {
this->setQueueBrowserPrefetch(Integer::parseInt(
- properties.getProperty("cms.PrefetchPolicy.queueBrowserPrefetch")));
+ properties.getProperty("cms.prefetchPolicy.queueBrowserPrefetch")));
}
- if (properties.hasProperty("cms.PrefetchPolicy.queuePrefetch")) {
+ if (properties.hasProperty("cms.prefetchPolicy.queuePrefetch")) {
this->setQueuePrefetch(Integer::parseInt(
- properties.getProperty("cms.PrefetchPolicy.queuePrefetch")));
+ properties.getProperty("cms.prefetchPolicy.queuePrefetch")));
}
- if (properties.hasProperty("cms.PrefetchPolicy.topicPrefetch")) {
+ if (properties.hasProperty("cms.prefetchPolicy.topicPrefetch")) {
this->setTopicPrefetch(Integer::parseInt(
- properties.getProperty("cms.PrefetchPolicy.topicPrefetch")));
+ properties.getProperty("cms.prefetchPolicy.topicPrefetch")));
}
- if (properties.hasProperty("cms.PrefetchPolicy.all")) {
- int value = Integer::parseInt(properties.getProperty("cms.PrefetchPolicy.all"));
+ if (properties.hasProperty("cms.prefetchPolicy.all")) {
+ int value = Integer::parseInt(properties.getProperty("cms.prefetchPolicy.all"));
this->setDurableTopicPrefetch(value);
this->setQueueBrowserPrefetch(value);
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/RedeliveryPolicy.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/RedeliveryPolicy.cpp?rev=1463791&r1=1463790&r2=1463791&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/RedeliveryPolicy.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/RedeliveryPolicy.cpp Tue Apr 2 23:26:19 2013
@@ -44,33 +44,33 @@ void RedeliveryPolicy::configure(const d
try {
- if (properties.hasProperty("cms.RedeliveryPolicy.backOffMultiplier")) {
+ if (properties.hasProperty("cms.redeliveryPolicy.backOffMultiplier")) {
this->setBackOffMultiplier(Double::parseDouble(
- properties.getProperty("cms.RedeliveryPolicy.backOffMultiplier")));
+ properties.getProperty("cms.redeliveryPolicy.backOffMultiplier")));
}
- if (properties.hasProperty("cms.RedeliveryPolicy.collisionAvoidancePercent")) {
+ if (properties.hasProperty("cms.redeliveryPolicy.collisionAvoidancePercent")) {
this->setCollisionAvoidancePercent(Short::parseShort(
- properties.getProperty("cms.RedeliveryPolicy.collisionAvoidancePercent")));
+ properties.getProperty("cms.redeliveryPolicy.collisionAvoidancePercent")));
}
- if (properties.hasProperty("cms.RedeliveryPolicy.initialRedeliveryDelay")) {
+ if (properties.hasProperty("cms.redeliveryPolicy.initialRedeliveryDelay")) {
this->setInitialRedeliveryDelay(Long::parseLong(
- properties.getProperty("cms.RedeliveryPolicy.initialRedeliveryDelay")));
+ properties.getProperty("cms.redeliveryPolicy.initialRedeliveryDelay")));
}
- if (properties.hasProperty("cms.RedeliveryPolicy.redeliveryDelay")) {
+ if (properties.hasProperty("cms.redeliveryPolicy.redeliveryDelay")) {
this->setRedeliveryDelay(Long::parseLong(
- properties.getProperty("cms.RedeliveryPolicy.redeliveryDelay")));
+ properties.getProperty("cms.redeliveryPolicy.redeliveryDelay")));
}
- if (properties.hasProperty("cms.RedeliveryPolicy.maximumRedeliveries")) {
+ if (properties.hasProperty("cms.redeliveryPolicy.maximumRedeliveries")) {
this->setMaximumRedeliveries(Integer::parseInt(
- properties.getProperty("cms.RedeliveryPolicy.maximumRedeliveries")));
+ properties.getProperty("cms.redeliveryPolicy.maximumRedeliveries")));
}
- if (properties.hasProperty("cms.RedeliveryPolicy.useCollisionAvoidance")) {
+ if (properties.hasProperty("cms.redeliveryPolicy.useCollisionAvoidance")) {
this->setUseCollisionAvoidance(Boolean::parseBoolean(
- properties.getProperty("cms.RedeliveryPolicy.useCollisionAvoidance")));
+ properties.getProperty("cms.redeliveryPolicy.useCollisionAvoidance")));
}
- if (properties.hasProperty("cms.RedeliveryPolicy.useExponentialBackOff")) {
+ if (properties.hasProperty("cms.redeliveryPolicy.useExponentialBackOff")) {
this->setUseExponentialBackOff(Boolean::parseBoolean(
- properties.getProperty("cms.RedeliveryPolicy.useExponentialBackOff")));
+ properties.getProperty("cms.redeliveryPolicy.useExponentialBackOff")));
}
}
DECAF_CATCH_RETHROW(Exception)