This is an automated email from the ASF dual-hosted git repository.
quinn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 73c76e3 Add XML support for retryAttemptedLogInterval
73c76e3 is described below
commit 73c76e30d268447b810c6985fd009f02aec8917c
Author: Quinn Stevenson <[email protected]>
AuthorDate: Tue May 29 16:00:39 2018 -0600
Add XML support for retryAttemptedLogInterval
---
.../camel/model/RedeliveryPolicyDefinition.java | 24 ++++++++++++++++++++++
.../AbstractCamelRedeliveryPolicyFactoryBean.java | 14 +++++++++++++
2 files changed, 38 insertions(+)
diff --git
a/camel-core/src/main/java/org/apache/camel/model/RedeliveryPolicyDefinition.java
b/camel-core/src/main/java/org/apache/camel/model/RedeliveryPolicyDefinition.java
index cfba6e9..11a2966 100644
---
a/camel-core/src/main/java/org/apache/camel/model/RedeliveryPolicyDefinition.java
+++
b/camel-core/src/main/java/org/apache/camel/model/RedeliveryPolicyDefinition.java
@@ -58,6 +58,8 @@ public class RedeliveryPolicyDefinition {
@XmlAttribute
private LoggingLevel retryAttemptedLogLevel;
@XmlAttribute
+ private String retryAttemptedLogInterval;
+ @XmlAttribute
private String logRetryAttempted;
@XmlAttribute
private String logStackTrace;
@@ -113,6 +115,9 @@ public class RedeliveryPolicyDefinition {
if (retryAttemptedLogLevel != null) {
answer.setRetryAttemptedLogLevel(retryAttemptedLogLevel);
}
+ if (retryAttemptedLogInterval != null) {
+
answer.setRetryAttemptedLogInterval(CamelContextHelper.parseInteger(context,
retryAttemptedLogInterval));
+ }
if (backOffMultiplier != null) {
answer.setBackOffMultiplier(CamelContextHelper.parseDouble(context,
backOffMultiplier));
}
@@ -313,6 +318,17 @@ public class RedeliveryPolicyDefinition {
}
/**
+ * Sets the interval to use for logging retry attempts
+ *
+ * @param retryAttemptedLogInterval the retry logging interval
+ * @return the builder
+ */
+ public RedeliveryPolicyDefinition retryAttemptedLogInterval(String
retryAttemptedLogInterval) {
+ setRetryAttemptedLogInterval(retryAttemptedLogInterval);
+ return this;
+ }
+
+ /**
* Sets whether stack traces should be logged.
* Can be used to include or reduce verbose.
*
@@ -714,6 +730,14 @@ public class RedeliveryPolicyDefinition {
this.retryAttemptedLogLevel = retryAttemptedLogLevel;
}
+ public String getRetryAttemptedLogInterval() {
+ return retryAttemptedLogInterval;
+ }
+
+ public void setRetryAttemptedLogInterval(String retryAttemptedLogInterval)
{
+ this.retryAttemptedLogInterval = retryAttemptedLogInterval;
+ }
+
public String getLogRetryAttempted() {
return logRetryAttempted;
}
diff --git
a/components/camel-core-xml/src/main/java/org/apache/camel/core/xml/AbstractCamelRedeliveryPolicyFactoryBean.java
b/components/camel-core-xml/src/main/java/org/apache/camel/core/xml/AbstractCamelRedeliveryPolicyFactoryBean.java
index 3ff146c..2e3ccd5 100644
---
a/components/camel-core-xml/src/main/java/org/apache/camel/core/xml/AbstractCamelRedeliveryPolicyFactoryBean.java
+++
b/components/camel-core-xml/src/main/java/org/apache/camel/core/xml/AbstractCamelRedeliveryPolicyFactoryBean.java
@@ -67,6 +67,9 @@ public abstract class
AbstractCamelRedeliveryPolicyFactoryBean extends AbstractC
@Metadata(defaultValue = "DEBUG", description = "Sets the logging level to
use for log messages when retries are attempted.")
private LoggingLevel retryAttemptedLogLevel;
@XmlAttribute
+ @Metadata(defaultValue = "0", description = "Sets the interval for log
messages when retries are attempted.")
+ private String retryAttemptedLogInterval;
+ @XmlAttribute
@Metadata(defaultValue = "true", description = "Sets whether to log retry
attempts")
private String logRetryAttempted;
@XmlAttribute
@@ -128,6 +131,9 @@ public abstract class
AbstractCamelRedeliveryPolicyFactoryBean extends AbstractC
if (retryAttemptedLogLevel != null) {
answer.setRetryAttemptedLogLevel(retryAttemptedLogLevel);
}
+ if (retryAttemptedLogInterval != null) {
+
answer.setRetryAttemptedLogInterval(CamelContextHelper.parseInteger(context,
retryAttemptedLogInterval));
+ }
if (backOffMultiplier != null) {
answer.setBackOffMultiplier(CamelContextHelper.parseDouble(context,
backOffMultiplier));
}
@@ -272,6 +278,14 @@ public abstract class
AbstractCamelRedeliveryPolicyFactoryBean extends AbstractC
this.retryAttemptedLogLevel = retryAttemptedLogLevel;
}
+ public String getRetryAttemptedLogInterval() {
+ return retryAttemptedLogInterval;
+ }
+
+ public void setRetryAttemptedLogInterval(String retryAttemptedLogInterval)
{
+ this.retryAttemptedLogInterval = retryAttemptedLogInterval;
+ }
+
public String getLogRetryAttempted() {
return logRetryAttempted;
}
--
To stop receiving notification emails like this one, please contact
[email protected].
