You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Philipp (Jira)" <ji...@apache.org> on 2020/11/26 07:47:00 UTC
[jira] [Commented] (CAMEL-15874) Every endpoint using RabbitMQ
creates a new connection instead of using only one connection
[ https://issues.apache.org/jira/browse/CAMEL-15874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239106#comment-17239106 ]
Philipp commented on CAMEL-15874:
---------------------------------
I increased the severity because when connection errors occur, the above described behavior results in:
* Hundreds of connections are created and canceled instead of only one
* This does not only increase a huge overhead but also spams the management dashboard "connections" view and the logs of the RabbitMQ
> Every endpoint using RabbitMQ creates a new connection instead of using only one connection
> -------------------------------------------------------------------------------------------
>
> Key: CAMEL-15874
> URL: https://issues.apache.org/jira/browse/CAMEL-15874
> Project: Camel
> Issue Type: Bug
> Components: camel-rabbitmq
> Affects Versions: 3.4.4
> Environment: OS Client: Linux 18.04
> OS Server: Linux 18.04
> Java: OpenJDK 11
> Camel: 3.4.4
> SpringBoot: 2.2.0
> Reporter: Philipp
> Priority: Major
> Attachments: 2020-11-20 16_56_05-RabbitMQ Management.png, 2020-11-20 16_57_16-RabbitMQ Management.png
>
>
> Consuming AMQP messages from RabbitMQ like the following results in multiple physical connections being set up and used. Instead of using one single connection and multiple channels per connection, as RabbitMQ [suggests|https://www.rabbitmq.com/channels.html].
> {code:xml}
> <route id="fooRoute">
> <!-- ... -->
> <from uri="rabbitmq:?queue=foo.queue&skipQueueBind=true"/>
> <!-- ... -->
> </route>
> <route id="barRoute">
> <!-- ... -->
> <from uri="rabbitmq:?queue=bar.queue&skipQueueBind=true"/>
> <!-- ... -->
> </route>
> {code}
> Also using the following configuration ...
> {code:yaml}
> camel:
> component:
> rabbitmq:
> autoDetectConnectionFactory: true
> skip-exchange-declare: true
> connection-factory: cachedConnectionFactory
> {code}
> {code:java}
> @Configuration
> public class Config{
> private final org.springframework.amqp.rabbit.connection.CachingConnectionFactory rabbitConnectionFactory;
> // ...
> @Bean
> com.rabbitmq.client.ConnectionFactory cachedConnectionFactory() {
> return rabbitConnectionFactory.getRabbitConnectionFactory();
> }
> }
> {code}
> ... results in the following log output:
> {code}
> 2020-11-20 16:35:13.854 DEBUG 17625 --- [ main] o.a.c.c.rabbitmq.RabbitMQConsumer : Using executor org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@4cd6f08b[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0][rabbitmq://?queue=foo.queue&skipQueueBind=true]
> 2020-11-20 16:35:13.881 DEBUG 17625 --- [ main] o.a.c.c.rabbitmq.RabbitMQConsumer : Created connection: amqp://ebb-client@10.131.67.XXX:5672/
> 2020-11-20 16:35:13.892 DEBUG 17625 --- [ main] o.a.c.component.rabbitmq.RabbitConsumer : Created channel: AMQChannel(amqp://ebb-client@10.131.67.XXX:5672/,1)
> 2020-11-20 16:35:13.903 INFO 17625 --- [ main] o.a.c.i.e.InternalRouteStartupManager : Route: foo_distributorRoute started and consuming from: rabbitmq://
> ...
> 2020-11-20 16:35:13.905 DEBUG 17625 --- [ main] o.a.c.c.rabbitmq.RabbitMQConsumer : Using executor org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@58835bba[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0][rabbitmq://?queue=bar.queue&skipQueueBind=true]
> 2020-11-20 16:35:13.914 DEBUG 17625 --- [ main] o.a.c.c.rabbitmq.RabbitMQConsumer : Created connection: amqp://ebb-client@10.131.67.XXX:5672/
> 2020-11-20 16:35:13.918 DEBUG 17625 --- [ main] o.a.c.component.rabbitmq.RabbitConsumer : Created channel: AMQChannel(amqp://ebb-client@10.131.67.XXX:5672/,1)
> 2020-11-20 16:35:13.925 INFO 17625 --- [ main] o.a.c.i.e.InternalRouteStartupManager : Route: bar_distributorRoute started and consuming from: rabbitmq://
> {code}
> See the attached screenshots from the RabbitMQ management dashboard.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)