RE: Camel RabbitMQ sink connector plugin is not getting added in Kafka Connect

Hi Andrea, Thanks a lot for the suggestion, it helped fix the issue, I can see the plugin. Regards, Gururaj -Original Message- From: Andrea Cosentino Sent: dinsdag 15 maart 2022 10:18 To: users@camel.apache.org Subject: Re: Camel RabbitMQ sink connector plugin is not getting added

Re: Camel RabbitMQ sink connector plugin is not getting added in Kafka Connect

You don't have to copy the jar, you need to explode the tar.gz provided: https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-rabbitmq-kafka-connector/0.11.5/camel-rabbitmq-kafka-connector-0.11.5-package.tar.gz Each of the connectors from camel-kafka-connector, needs to live

Camel RabbitMQ sink connector plugin is not getting added in Kafka Connect

Hi all, I'm trying a setup in which I need to push data from Kafka to RabbitMQ. I'm using Debezium Kafka Connect base image and adding additional plugins as required. As sink connector to RabbitMQ, I'm trying out Camel RabbitMQ connector plugin. I've copied the plugin jar in the plugin.path

RE: [camel-rabbitmq] - InOut pattern and temporary queues

@camel.apache.org Objet : Re: [camel-rabbitmq] - InOut pattern and temporary queues On Wed, Jun 9, 2021 at 4:40 PM FERRY, Guillaume wrote: > > Hi folks, > > Here's a quick follow-up on my work with camel-rabbitmq. > So far, everything runs quite smoothly, but in some particular cases, s

Re: [camel-rabbitmq] - InOut pattern and temporary queues

On Wed, Jun 9, 2021 at 4:40 PM FERRY, Guillaume wrote: > > Hi folks, > > Here's a quick follow-up on my work with camel-rabbitmq. > So far, everything runs quite smoothly, but in some particular cases, some > messages being sent on a queue are not received on the othe

RE: [camel-rabbitmq] - InOut pattern and temporary queues

Hi folks, Here's a quick follow-up on my work with camel-rabbitmq. So far, everything runs quite smoothly, but in some particular cases, some messages being sent on a queue are not received on the other side. Here's the relevant log section : DEBUG o.a.c.c.r.RabbitMQMessagePublisher - Sending

RE: [camel-rabbitmq] - InOut pattern and temporary queues

: [camel-rabbitmq] - InOut pattern and temporary queues Hi Guillaume, Yes, that’s probably the easiest way. To complete a little: - the correlation can be done on the request message id using a temp destination - the correlation can be done on the client ID using physical destinations Most

Re: [camel-rabbitmq] - InOut pattern and temporary queues

est regards, > Guillaume. > > De : ski n > Envoyé : mardi 11 mai 2021 15:38 > À : users@camel.apache.org > Objet : Re: [camel-rabbitmq] - InOut pattern and temporary queues > > When working with a Request-Reply pattern the reply message needs to send > to a sec

RE: [camel-rabbitmq] - InOut pattern and temporary queues

Hi Raymond, Thanks a lot for this crystal clear answer. I'll let Camel handle theses queues, then ! Best regards, Guillaume. De : ski n Envoyé : mardi 11 mai 2021 15:38 À : users@camel.apache.org Objet : Re: [camel-rabbitmq] - InOut pattern and temporary queues

Re: [camel-rabbitmq] - InOut pattern and temporary queues

ked, and returns its value (which I get > as a response for my REST call) > > However, I noticed a temporary queue amq.gen.XXX has been created > automatically, to handle the reply. > Is it the standard behaviour ? > > Before using camel-rabbitmq, we were relying on camel-spri

[camel-rabbitmq] - InOut pattern and temporary queues

a temporary queue amq.gen.XXX has been created automatically, to handle the reply. Is it the standard behaviour ? Before using camel-rabbitmq, we were relying on camel-spring-amqp (https://github.com/Bluelock/camel-spring-amqp), which is now obsolete (and triggered the switch to camel-rabbitmq

Re: Camel + RabbitMQ + SSL

Hi Phil, I presume that the camel-rabbitmq component is picking up and using this ConnectionFactory: ... So I would see if SSL needs to be configured there, and not on the Camel endpoint. Try setting the "useSslProtocol" [1] property on the ConnectionFactory itself? (i.e. set it as

Camel + RabbitMQ + SSL

Hello: I am using Camel 2.24.3 and RabbitMQ 3.17.7. I have been able to successfully build a Camel program to ingest data from my input source and send the results to RabbitMQ. I am happy with the results. Now I am required to use SSL between my Camel program and RabbitMQ. Both my Camel

Camel-RabbitMQ support for multiple inflight exchanges without autoAck

multiple inflight exchanges. The only solution around it, is to add more consumers. I tested by applying the following changes https://github.com/maragud/camel-rabbitmq/commit/9f695c1dff05b8e4cc1004ea242c210fd10e59b1 which could deliver up to the number of prefetched messages to each consumer

camel-rabbitmq component issue

address pool. According to doc of camel rabbitmq component it should bind to other address in the pool but its not happening in the above scanerio. Below is the attached error log file. But the above setup is working perfect in the case of HA mirroring using classic queue type and it is able to switch to

Re: Proposal : camel-rabbitmq : RabbitMQProducer to override EXCHANGE_NAME/ROUTING_KEY headers if bridgeEndpoint

Hi, You are welcome to do so. Please raise a JIRA ticket and then send your PR. Regards, Omar On Mon, Jan 20, 2020 at 4:15 PM Jonathan Schoreels < jonathan.schore...@gmail.com> wrote: > Hi, > > Currently, the camel-rabbitmq endpoints, if set as "bridgeEndpoint"

Proposal : camel-rabbitmq : RabbitMQProducer to override EXCHANGE_NAME/ROUTING_KEY headers if bridgeEndpoint

Hi, Currently, the camel-rabbitmq endpoints, if set as "bridgeEndpoint", ignores the following exchange's headers : EXCHANGE_NAME & ROUTING_KEY, but it keeps the previous headers setted, which leak information about the origin of the event. For example, if my message comes from

Re: Camel-RabbitMQ-STOMP

Hi Mahesh, The error above is related to the initial creation of the Camel route, is pretty weird though that it can't parse the options although you correctly spelled them. Which version of Camel do you use? Also, in regards camel stomp with RabbitMQ, I honestly have no idea if it is going to

Camel-RabbitMQ-STOMP

Hi All, I am new to message brokers. I successfully completed a POC using Spring Reactor Netty Stomp client (Spring messaging framework) to connect to RabbitMQ on port 61613 (port dedicated for STOMP). That was just a POC. Now i have to build something concrete to be able to deploy in prod

Re: How to get route Exception in a processor with camel+rabbitmq

In ActiveMQ component there is a "transferExchange" URI parameter, which makes possible to get the exception after sending it to another queue through activemq. Is there a way of doing this (transfer the exchange over the messaging layer) with RabbitMQ? Em qua., 13 de nov. de 2019 às 17:45,

Re: How to get route Exception in a processor with camel+rabbitmq

Hi .. "myExchange" is not the queue name... When working with rabbitmq, you always send the message to a "RabbitMQ Exchange", which redirects it to some queue based on the routingKey (which is defined on the creation of the queue)... quite complex, but RabbitMQ component has different concepts

Re: How to get route Exception in a processor with camel+rabbitmq

why your from queue name is same as to queue name? On Wed, Nov 13, 2019 at 9:10 AM Alessandro Hoss wrote: > Hello guys, > > I've a route with onException, which sends the message to rabbitMQ, and > another route listening rabbit to call a processor and get the exception > thrown. I'm able to

How to get route Exception in a processor with camel+rabbitmq

Hello guys, I've a route with onException, which sends the message to rabbitMQ, and another route listening rabbit to call a processor and get the exception thrown. I'm able to reach this processor, but i'm not able to get the exception thrown. I've tried with the property set to false, and

RE: camel-rabbitmq sheduled route acks all messages when shutting down

tead of the body expression and it still wouldn't populate the header. From: Valdis Andersons Sent: 05 November 2019 21:54 To: users@camel.apache.org Subject: RE: camel-rabbitmq sheduled route acks all messages when shutting down CAUTION: This email originated from outside of VHI. Do not click link

RE: camel-rabbitmq sheduled route acks all messages when shutting down

sing for each archived item (since they can go different ways and also fail in all sorts of different ways). Any help/advice/hint on the above would be greatly appreciated. Thanks and Regards, Valdis From: Valdis Andersons Sent: 05 November 2019 15:59 To: users@camel.apache.org Subject: camel-

camel-rabbitmq sheduled route acks all messages when shutting down

Hi All, Not sure I understand the issue fully, but I have scheduled route with this config (it's throttled as well): CronScheduledRoutePolicy emailSchedulingPolicy = new CronScheduledRoutePolicy(); emailSchedulingPolicy.setRouteStartTime(emailNotificationsStartSchedule);

camel-rabbitmq - New URI format - The RabbitMQ channel is not open - Connection refused

-5.5.0.jar:5.5.0]* * at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1063) ~[amqp-client-5.5.0.jar:5.5.0]* * at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1021) ~[amqp-client-5.5.0.jar:5.5.0]* * at com.ra

RE: camel-rabbitmq automated recovery

ubject: Re: camel-rabbitmq automated recovery Hi Have you been able to try with a newer release such as Camel 2.23.0, as the camel-rabbitmq component etc may been improved / bug fixed since that version you are using. On Mon, Nov 12, 2018 at 5:34 PM Valdis Andersons wrote: > > Hi All, > &

Re: camel-rabbitmq automated recovery

Hi Have you been able to try with a newer release such as Camel 2.23.0, as the camel-rabbitmq component etc may been improved / bug fixed since that version you are using. On Mon, Nov 12, 2018 at 5:34 PM Valdis Andersons wrote: > > Hi All, > > > > Hoping someone wi

camel-rabbitmq automated recovery

Hi All, Hoping someone with more experience with RabbitMQ and Camel might be able to tell me what's going on with the below scenario as I'm not sure I understand it right. We have now 3 servers in a test environment with RabbitMQ installed (v3.6.12, Elang 20.1), we're using camel-rabbitmq

Re: Going from ‘camel-rabbitmq’ to custom messaging class

it in your routes with from / to etc and replace the existing rabbitmq component. A bean component can only do it in the to and not in from. So a custom camel component is possible your better option. On Tue, Oct 9, 2018 at 4:20 AM Ron wrote: > > > Hi, all. > > I’ve been successfully u

Going from ‘camel-rabbitmq’ to custom messaging class

Hi, all. I’ve been successfully using the ‘camel-rabbitmq’ component and love it. However, I’ve unfortunately been tasked to replace it with an in-house custom class we’ve used on a number of projects to write/read to/from our RabbitMQ bus. To do this, do I need to create a new custom

camel-rabbitmq clustering failover issue

Hi All, Hopefully someone can help me out here. In the project I'm working on we're using the camel-rabbitmq component to connect to a cluster of three RabbitMQ nodes. We're using the addresses parameter in the URL configuration of the RabbitMQ facing endpoints, like this: from:rabbitmq

Re: Apache Camel - rabbitmq - ssl ( not working )

.1.0] > at > com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:996) > ~[amqp-client-4.1.0.jar!/:4.1.0] > at > org.apache.camel.component.rabbitmq.RabbitMQEndpoint.connect(RabbitMQEndpoint.java:248) > ~[camel-rabbitmq-2.20.2.jar!/:2.2

Apache Camel - rabbitmq - ssl ( not working )

28) ~[amqp-client-4.1.0.jar!/:4.1.0] at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:996) ~[amqp-client-4.1.0.jar!/:4.1.0] at org.apache.camel.component.rabbitmq.RabbitMQEndpoint.connect(RabbitMQEndpoint.java:248) ~[camel-rabbitmq-2.20.2.ja

Re: Apache camel - rabbitmq - ssl ( not working )

Pls advise on the possible causes of this or if more information is needed On Mon, Mar 26, 2018, 11:24 PM Pranay Tonpay wrote: > I am trying to use apache camel ( camel-spring-boot - 2.20.2 ) with > rabbitmq and create routes. It does work fine when iI use un-secured >

camel-rabbitmq autorecovery causes multiple channels opened

I was trying to implement a camel-rabbitmq application which connects to a clustered+ha rabbitmq backend server. The connection is working fine and is able to poll from a mirrored queue. When running the application, 2 threads are created for the rabbitmq connection: <http://camel.465427

camel-rabbitmq multiple bindings/routing keys

Hello, Does the camel-rabbitmq component support multiple bindings on a queue? That is, can a route consume a rabbit endpoint from(rabbitmq://...) and subscribe to a queue with multiple routing keys? It is supported by standard rabbitmq but wondering if the Camel component supports it as well

Re: Camel RabbitMQ

Ok I figured out what the issue is. You must explicitly set the exchangepattern to InOut otherwise the replyto headers and queues are not created by default. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-RabbitMQ-tp5781455p5781457.html Sent from the Camel - Users

Camel RabbitMQ

Souciance -- View this message in context: http://camel.465427.n5.nabble.com/Camel-RabbitMQ-tp5781455.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-rabbitmq transaction support for version 2.15

Hi all, is Camel version 2.15 supports transaction with rabbitmq also replyTo is not seems to be working for rabbitmq , is that also not supported for 2.15 thanks, Prajath -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-transaction-support-for-version-2-15

Re: camel-rabbitmq logging exceptions as debug

Hi Yeah that sounds like we should improve this. Feel free to log a JIRA ticket http://camel.apache.org/support On Thu, Oct 23, 2014 at 11:08 AM, Marco Crivellaro marco.cr...@gmail.com wrote: Hi, I am using Camel 2.14.0 Connecting to RabbitMQ using camel-rabbitmq I've noticed that no ERROR

Re: camel-rabbitmq logging exceptions as debug

opened https://issues.apache.org/jira/browse/CAMEL-7967 thanks -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-logging-exceptions-as-debug-tp5757936p5758069.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel-rabbitmq only receive one message when autoAck is false

anybody can help? Thanks, Jeffrey -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-only-receive-one-message-when-autoAck-is-false-tp5758034p5758121.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-rabbitmq only receive one message when autoAck is false

Hi, When I use camel-rabbitmq in my project, if I set autoAck to false, I can only receive one message even though the prefetchCount was set to a big number. I have to ack the message then I will get the next message. I was hoping to get multiple messages and send to multiple workers to process

camel-rabbitmq logging exceptions as debug

Hi, I am using Camel 2.14.0 Connecting to RabbitMQ using camel-rabbitmq I've noticed that no ERROR is logged if the component cannot connect, the exceptions are handled and logged as DEBUG. This is a bit inconvenient as logging all DEBUG messages for the component fills up our logs, in production

Re: Camel RabbitMQ acknowledges event though autoAck is set to false and there is an exception in the route

Thanks Claus Ibsen for looking into this. Let me know when this fix will be available. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-RabbitMQ-acknowledges-event-though-autoAck-is-set-to-false-and-there-is-an-exception-in-the-roe-tp5756207p5756229.html Sent from

Camel RabbitMQ acknowledges event though autoAck is set to false and there is an exception in the route

Camel RabbitMQ component acknowledges the message even though the autoAck is set to false and there is an exception in the route. I don't know if I am doing anything wrong. My guess is that the error could be in the RabbitMQConsumer class. try { consumer.getProcessor().process

Re: Camel RabbitMQ acknowledges event though autoAck is set to false and there is an exception in the route

Hi Yeah you are right I am fixing this now. On Mon, Sep 8, 2014 at 8:35 PM, blr_developer sridhar2...@gmail.com wrote: Camel RabbitMQ component acknowledges the message even though the autoAck is set to false and there is an exception in the route. I don't know if I am doing anything wrong

Camel RabbitMQ acknowledge messages

Hi, We are using RabbitMQ for messaging huge amount of data. For good performance multi acknowledgment of messages is used. Further we send messages from RabbitMQ via EventManager for processing. After a batch we store results in data base and acknowledge processed messages. We would like to

Re: Camel RabbitMQ acknowledge messages

Hi, If you set the option of autoAck is false, Camel will send the acknowledgement to RabbitMQ when the exchange is processed.  If you want to do it in the batch mode, you may need to change the  RabbitMQConsumer, but I’m not sure how can get the channel if you want to send the acknowledgement

Re: camel-rabbitmq

Thank you Willem. After upgrading to 2.13.0 and adding BridgeEndpoint=true to the URI solved this issue. I ended up using addresses as we have 2 RabbitMQ in a cluster. Thanks, Muthu -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-routing-issue

Re: camel-rabbitmq

rabbitmq headers which causes Camel to keep sending same message to the general.queue? If so I will exclude only that particular header. Thanks, Muthu -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-routing-issue-tp5744371p5749441.html Sent from the Camel - Users

Re: camel-rabbitmq

Hi, If you use camel 2.13.0, you can specify the option of BridgeEndpoint=true, then camel rabbitmq can ignore the message header which are set by camel rabbitmq consumer. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http

RE: camel-rabbitmq autoack=false

Willem, I reverted the change below on a private copy of camel-rabbitmq in RabbitMQConsumer.class, and reverting that change fixed my problem, allowing me to NOT autoAck. Could you please consider reverting this fix in the code? Here is a link to the commit: https://github.com/apache/camel

RE: camel-rabbitmq autoack=false

Willem, I updated to 2.12.3, and still have the same problem. I believe there is a bug in the code, it camel-rabbitmq-2.12.3.jar, RabbitMQConsumer.class, line 126: if (!consumer.endpoint.isAutoAck()) { log.trace(Acknowledging receipt [delivery_tag

camel-rabbitmq autoack=false

I am creating an endpoint as follows using camel-rabbitmq (2.12.2). The endpoint works fine, but appears to be doing an acknowledge even though autoAck=false. String endpoint = rabbitmq:// + host + : + port + / + exchange + ?username= + username + password= + password

Re: camel-rabbitmq autoack=false

: willemjiang Weibo: 姜宁willem On March 11, 2014 at 9:22:53 AM, John H. Clark (johcl...@adobe.com) wrote: I am creating an endpoint as follows using camel-rabbitmq (2.12.2). The endpoint works fine, but appears to be doing an acknowledge even though autoAck=false. String endpoint = rabbitmq

camel rabbitmq request-reply

this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-request-reply-tp5745861.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Message properties missing after Camel - rabbitmq routing

The correlation_id and reply_to header are removed in removeHeaders pattern=rabbitmq.*/ You can find more information about the rabbitmq.* header here[1] [1]https://github.com/apache/camel/blob/master/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq

Re: Message properties missing after Camel - rabbitmq routing

Thanks Willem Kraythe for your reply -- View this message in context: http://camel.465427.n5.nabble.com/Message-properties-missing-after-Camel-rabbitmq-routing-tp5745254p5745507.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Message properties missing after Camel - rabbitmq routing

-after-Camel-rabbitmq-routing-tp5745254.html Sent from the Camel - Users mailing list archive at Nabble.com.

Message properties missing after Camel - rabbitmq routing

as you can see message properties like reply_to, correlation_id are missing. http://camel.465427.n5.nabble.com/file/n5745254/out.png Can someone help me with this. Thanks, Muthu -- View this message in context: http://camel.465427.n5.nabble.com/Message-properties-missing-after-Camel-rabbitmq

Re: camel-rabbitmq

Thanks Willem -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-routing-issue-tp5744371p5744410.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-rabbitmq

in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-tp5744371.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel-rabbitmq

change the to route as /uri=log:com.mycompany.order?level=INFO// it logs the message properly in the log and only once. Any help or suggestions?. Thanks. Muthu -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-tp5744371.html Sent from the Camel - Users mailing

Re: camel-rabbitmq

Thanks Willem for the quick response. Your suggestion resolved my issue. Can you please explain why this issue happened and how this fixed it? Thanks, Muthu -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-routing-issue-tp5744371p5744374.html Sent from

Re: camel-rabbitmq

it? Thanks, Muthu -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-routing-issue-tp5744371p5744374.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel RabbitMQ component - Increasing File Descriptors

Camel RabbitMQ component (v2.12.0) to publish message on RabbitMQ. We are using dynamic slip router to publish the messages to the endpoint (like, rabbitmq://xxx.xxx.xxx.xxx (http://xxx.xxx.xxx.xxx):/exchange) something like below, .dynamicRouter(method

Re: Camel-rabbitmq - how to handle endpoint not available?

and if it fails, then the Camel error handler can react. On the consumer side its more tricky as you would need a background job that re-attempts to get a connection to the rabbit broker. Maybe we can add such functionality to camel-rabbitmq. 2) All this failover and reconnect stuff is built

Camel RabbitMQ component - Increasing File Descriptors

Hi all, We are using Camel RabbitMQ component (v2.12.0) to publish message on RabbitMQ. We are using dynamic slip router to publish the messages to the endpoint (like, rabbitmq://xxx.xxx.xxx.xxx:/exchange) something like below, .dynamicRouter(method(ServiceRouter.class, slip

Re: Camel RabbitMQ component - Increasing File Descriptors

:27 PM, Mayank Mishra wrote: Hi all, We are using Camel RabbitMQ component (v2.12.0) to publish message on RabbitMQ. We are using dynamic slip router to publish the messages to the endpoint (like, rabbitmq://xxx.xxx.xxx.xxx (http://xxx.xxx.xxx.xxx):/exchange) something like

Re: Camel RabbitMQ component - Increasing File Descriptors

) http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁willem On Thursday, November 7, 2013 at 2:27 PM, Mayank Mishra wrote: Hi all, We are using Camel RabbitMQ component (v2.12.0) to publish message on RabbitMQ. We are using dynamic slip router

Camel-rabbitmq - how to handle endpoint not available?

I'm trying to use Camel embedded into an application (Spring configured) to push files from a local directory to an instance of RabbitMQ. It's been working well so far, except in the case where RabbitMQ is not available for some reason (network outage, maintenance, etc.), and our application

Re: camel-rabbitmq : not able to publish messages

Hi Could you tell me where have you mentioned the name of the Queue? Alternatively please let me know how it behaves when you remove noop-true Cheers Reji On Wed, Oct 16, 2013 at 3:45 PM, tsv [via Camel] ml-node+s465427n5741707...@n5.nabble.com wrote: Greetings, I am using camel-rabbitmq

Re: camel-rabbitmq : not able to publish messages

Hey What is the name of the queue? And also try removing noop =true and let me know how it behaves cheers Reji tsv [via Camel] ml-node+s465427n5741707...@n5.nabble.com wrote: Greetings, I am using camel-rabbitmq component to publish messages to rabbitmq broker. But I see my route opens

Re: camel-rabbitmq : not able to publish messages

. Is the camel-rabbitmq component support AMQP versions 0-9-1 or 0-9 or 0-8 or its just 1.0 or 0.10. As RabbitMQ will perform protocol negotiation with the clients implementing 0-9-1, 0-9 and 0-8 only. Thanks, tsv -- View this message in context: http://camel.465427.n5.nabble.com/camel

Re: camel-rabbitmq : not able to publish messages

'queue=myqueue'. By removing noop=true did not help, it’s behaving the same, rabbitmq connection is opened and no channel, exchange, queue or message is created. I even replaced RabbitMQ Client version to:2.8.2 from: 3.1.5 this also has no effect. Is the camel-rabbitmq component support AMQP

Re: camel-rabbitmq : not able to publish messages

.nabble.com/camel-rabbitmq-not-able-to-publish-messages-tp5741707p5741800.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-rabbitmq : not able to publish messages

Greetings, I am using camel-rabbitmq component to publish messages to rabbitmq broker. But I see my route opens a connection in rabbitmq server (viewed from rabbitmq web admin management console) but never creates a channel, exchange, queue and the message. Here is my route config: from(file:src

Re: Camel RabbitMQ from 2.12 snapshot - missing parameter type:direct

Hi Camel RabbitMQ doesn't support to set the type currently. The type value is direct, with the code like this: channel.exchangeDeclare(endpoint.getExchangeName(), direct, endpoint.isDurable(), endpoint.isAutoDelete(), new HashMapString, Object()); I just found the below code doesn't follow

Re: Camel RabbitMQ from 2.12 snapshot - missing parameter type:direct

Hi Willem, Thanks for your quick reply. Thanks, Tushar -- View this message in context: http://camel.465427.n5.nabble.com/Camel-RabbitMQ-from-2-12-snapshot-missing-parameter-type-direct-tp5738013p5738026.html Sent from the Camel - Users mailing list archive at Nabble.com.

Camel RabbitMQ from 2.12 snapshot - missing parameter type:direct

://camel.apache.org/rabbitmq.html. But I do not find an option for 'type'. May this be the problem ? What am I missing ? Thanks for your time. Tushar -- View this message in context: http://camel.465427.n5.nabble.com/Camel-RabbitMQ-from-2-12-snapshot-missing-parameter-type-direct-tp5738013.html Sent from

Re: camel rabbitmq

I ran into this as well and can be worked around by adding this between your from and to: .setHeader(RabbitMQConstants.EXCHANGE_NAME).constant(A) -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq

camel-rabbitmq producer is not including the body

Trying to consume from rabbitmq using the camel-rabbitmq component and the problem is the body of the message is not being passed down the line. Debugging and looking at the source, I see that in RabbitMQConsumer.RabbitConsumer.handleDelivery that the body is being passed into the method

Re: camel-rabbitmq producer is not including the body

(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁willem On Thursday, August 8, 2013 at 4:44 AM, dalewking wrote: Trying to consume from rabbitmq using the camel-rabbitmq component and the problem

camel rabbitmq

Hi I tried to use camel-rabbitmq component from 2.12 snapshot. Here is my route. from(netty:tcp://0.0.0.0:7000?textline=true).to(rabbitmq://localhost/A?routingKey=Busername=guestpassword=guest); And I am getting null pointer exception. Here is full stacktrace Stacktrace

Re: camel rabbitmq

Hi Thanks for reporting. I am fixing this on master. On Tue, Jul 30, 2013 at 12:43 PM, kiranreddykasa kirankuma...@fss.co.in wrote: Hi I tried to use camel-rabbitmq component from 2.12 snapshot. Here is my route. from(netty:tcp://0.0.0.0:7000?textline=true).to(rabbitmq://localhost

Re: Failed to connect using Camel + RabbitMq Configuration

, Apart from QPID, Do we have any other routes to connect to RabbitMQ, . If so, can you kindly share the configuration.. Regards Jawahar -- View this message in context: http://camel.465427.n5.nabble.com/Failed-to-connect-using-Camel-RabbitMq-Configuration-tp5721351p5721366.html

Re: Failed to connect using Camel + RabbitMq Configuration

Thanks William, Apart from QPID, Do we have any other routes to connect to RabbitMQ, . If so, can you kindly share the configuration.. Regards Jawahar -- View this message in context: http://camel.465427.n5.nabble.com/Failed-to-connect-using-Camel-RabbitMq-Configuration-tp5721351p5721366

Re: Failed to connect using Camel + RabbitMq Configuration

this message in context: http://camel.465427.n5.nabble.com/Failed-to-connect-using-Camel-RabbitMq-Configuration-tp5721351p5721366.html Sent from the Camel - Users mailing list archive at Nabble.com (http://Nabble.com).

Failed to connect using Camel + RabbitMq Configuration

): connection_closed_abruptly Kindly let me know what needs to be done.. Thanks REgards Jawahar -- View this message in context: http://camel.465427.n5.nabble.com/Failed-to-connect-using-Camel-RabbitMq-Configuration-tp5721351.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Failed to connect using Camel + RabbitMq Configuration

=== closing AMQP connection 0.783.0 (127.0.0.1:3917 - 127.0.0.1:5672): connection_closed_abruptly Kindly let me know what needs to be done.. Thanks REgards Jawahar -- View this message in context: http://camel.465427.n5.nabble.com/Failed-to-connect-using-Camel-RabbitMq