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)
