You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Jörg Gonschior (Jira)" <ji...@apache.org> on 2020/12/01 15:36: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=17241637#comment-17241637 ]
Jörg Gonschior commented on CAMEL-15874:
----------------------------------------
Working with Philipp at the same project.
Tested both, but it ends up in multiple connections. The desired scenario of only one connection using multiple channels was not reached.
1.
{code:java}
autoDetectConnectionFactory: true
# connection-factory: cachedConnectionFactory #inactive
{code}
{code:java}
pom.xml does not contain: spring-boot-starter-amqp
{code}
{code:java}
above Configuration class is not present
{code}
Result:
Instead of one connection 2 are added. Both connections are created from the <from uri expression.
||Name||username||...||
|{{10.131.65.XXX:60427}}
{{~?~}}|{{rabbit-admin}}| |
|{{10.131.65.XXX:60425}}
{{~?~}}|{{rabbit-admin}}| |
|...| | |
(ASCII art from Rabbit console)
2.
{code:java}
autoDetectConnectionFactory: false
connection-factory: cachedConnectionFactory #active
{code}
{code:java}
pom.xml contains: spring-boot-starter-amqp
{code}
{code:java}
above Configuration class is present
{code}
Result:
Instead of one connection 3 are added. 2 connections with the name "?" are created from the <from uri expression. The third one comes from the dependency spring-boot-starter-amqp. This dependency is needed to be able to use the class org.springframework.amqp.rabbit.connection.CachingConnectionFactory in the config class.
Adding this we have to configure the rabbitMQ connection for Spring additionally using the properties:
{code:java}
spring:
rabbitmq:
host: my-simulation-server
port: 5672
username: rabbit-admin
password: xxx
{code}
||Name||username||...||
|{{10.131.65.XXX:60420}}
{{~rabbitConnectionFactory#3b57dba4:0~}}|{{rabbit-admin}}| |
|{{10.131.65.XXX:60427}}
{{~?~}}|{{rabbit-admin}}| |
|{{10.131.65.XXX:60425}}
{{~?~}}|{{rabbit-admin}}| |
|...| | |
(ASCII art from Rabbit console)
> 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)