[camel] branch master updated: CAMEL-16366: camel-spring-rabbitmq - RabbitMQ consumer supports exchange pooling

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus 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 e3d5e5b  CAMEL-16366: camel-spring-rabbitmq - RabbitMQ consumer 
supports exchange pooling
e3d5e5b is described below

commit e3d5e5b7ea2cc8c1044b091fb7134e9bcabdbdf8
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Apr 12 18:00:39 2021 +0200

    CAMEL-16366: camel-spring-rabbitmq - RabbitMQ consumer supports exchange 
pooling
---
 .../apache/camel/component/springrabbit/EndpointMessageListener.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java
 
b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java
index 84e5d59..24bd2ae 100644
--- 
a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java
+++ 
b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java
@@ -125,6 +125,8 @@ public class EndpointMessageListener implements 
ChannelAwareMessageListener {
                 } catch (Exception e) {
                     exchange.setException(e);
                 } finally {
+                    // release back when synchronous mode
+                    consumer.releaseExchange(exchange, false);
                     callback.done(true);
                 }
             } else {