Loading...

XML

Word

Printable

GSS Priority:
Steps to Reproduce:
Hide

1. Start Fuse 6.3
2. Install camel-amqp feature
3. Build, install and start reproducer

You'll note that the producer hangs and eventually the broker gives up waiting for the producer to complete the connection process and throws a InactivityIOException. When you stop the reproducer's bundle, you'll note that Camel reports in-flight exchange

11:29:52,011 | DEBUG | 1 - ShutdownTask | DefaultShutdownStrategy | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | There are 1 inflight exchanges:n | InflightExchange: [exchangeId=ID-Joe-Fernandezs-iMac-local-62969-1480609689393-0-2, fromRouteId=amqp-producer, routeId=amqp-producer, nodeId=to1, elapsed=100731, duration=100823]
Show
1. Start Fuse 6.3 2. Install camel-amqp feature 3. Build, install and start reproducer You'll note that the producer hangs and eventually the broker gives up waiting for the producer to complete the connection process and throws a InactivityIOException. When you stop the reproducer's bundle, you'll note that Camel reports in-flight exchange 11:29:52,011 | DEBUG | 1 - ShutdownTask | DefaultShutdownStrategy | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | There are 1 inflight exchanges:n | InflightExchange: [exchangeId=ID-Joe-Fernandezs-iMac-local-62969-1480609689393-0-2, fromRouteId=amqp-producer, routeId=amqp-producer, nodeId=to1, elapsed=100731, duration=100823]

Simple AMQP producer hangs when attempting to connect to the A-MQ broker. Seems to hang on a countdown latch (see attached thread dump).

at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
at org.apache.qpid.jms.provider.ProviderFuture.sync(ProviderFuture.java:97)

Reproducer has been attached; its derived from example in http://camel.apache.org/amqp.html