[camel] branch master updated: Add XML support for retryAttemptedLogInterval

[quinn]

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 <qu...@apache.org>
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
qu...@apache.org.