I'm working on CAMEL-8742 where RabbitMQ consumers will never reconnect if
the RabbitMQ channel gets closed.
Its actually really easy to detect when the channel is closed because the
com.rabbitmq.client.Consumer interface has a handleShutdownSignal() method
that will get called. However I would ap
What is the projects policy with using Java7 syntax (specifically try with
resources)? I assumed it was allowed but am getting errors when running mvn
compile -Psourcecheck
I added a try with resources to the camel-rabbitmq component but the
maven-checkstyle-plugin version 2.9.1 doesn't allow it.
I still have some things to clean up and a few more tests to write but I'd
like to start getting some comments:
https://github.com/brreitme/camel/commit/b77e1297f2f8371257a36e56c9cfd096720c39ca
--
View this message in context:
http://camel.465427.n5.nabble.com/Adding-inOut-support-to-the-Rabbi
I went ahead and added the ability for it to natively support sending any
object that implements Serializable. There were several places that were
converting the body of the exchange to a byte[] then calling
channel.basicPublish(...). I combined all of them into this one method. I'm
not a fan of us
I have it working (at least for direct exchanges) but I ended up with some
duplicated code from the camel-jms component. A few example are the
CorrelationTimeoutMap, CorrelationListener, QueueReplyHandler classes. What
is the right thing to?
1) Add camel-jms as a dependency of camel-rabbitmq
2) M
Hi Claus,
I searched jira last week and didn't see anything related. CAMEL-7860 added
the reply ability that I need but it still doesn't start up a temporary
reply queue and handle timeouts ect. Should I create a new feature jira?
--
View this message in context:
http://camel.465427.n5.nabble.c
I need the ability to use inOut routes with the RabbitMQ component and am
about start working on adding it myself.
1) I wanted to make sure no one else was working this?
2) I'm planing on making RabbitMQProducer extend DefaultAsyncProducer and
writing a temporary reply manager similar to the Jms
