camel-spring-rabbitmq: Fix configuration of consumer retry settings

Author: jamesnetherton

components/camel-spring-parent/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/DefaultListenerContainerFactory.java

@@ -16,6 +16,8 @@
  */
 package org.apache.camel.component.springrabbit;
 
+import java.time.Duration;
+
 import org.springframework.amqp.core.AmqpAdmin;
 import org.springframework.amqp.rabbit.config.RetryInterceptorBuilder;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
@@ -69,17 +71,22 @@ public AbstractMessageListenerContainer createListenerContainer(SpringRabbitMQEn
             listener.setAdviceChain(endpoint.getRetry());
         } else {
             RetryInterceptorBuilder<?, ?> builder = RetryInterceptorBuilder.stateless();
+            RetryPolicy.Builder retryPolicyBuilder = RetryPolicy.builder();
+
             if (endpoint.getMaximumRetryAttempts() <= 0) {
-                builder.retryPolicy(RetryPolicy.withMaxRetries(0));
+                retryPolicyBuilder.maxRetries(0);
             } else if (endpoint.getMaximumRetryAttempts() > 0) {
-                builder.retryPolicy(RetryPolicy.withMaxRetries(endpoint.getMaximumRetryAttempts()));
+                retryPolicyBuilder.maxRetries(endpoint.getMaximumRetryAttempts());
             }
             if (endpoint.getRetryDelay() > 0) {
-                builder.backOffOptions(endpoint.getRetryDelay(), 1, endpoint.getRetryDelay());
+                retryPolicyBuilder.delay(Duration.ofMillis(endpoint.getRetryDelay()));
+                retryPolicyBuilder.multiplier(1);
+                retryPolicyBuilder.maxDelay(Duration.ofMillis(endpoint.getRetryDelay()));
             }
             if (endpoint.isRejectAndDontRequeue()) {
                 builder.recoverer(new RejectAndDontRequeueRecoverer());
             }
+            builder.retryPolicy(retryPolicyBuilder.build());
             listener.setAdviceChain(builder.build());
         }