InOut exchange pattern on Transactional JMS endpoint not working

2019-08-07 Thread sujin sr
Hi, I have a use case where two jms queues are available those are DataRequestQueue and DataReplyQueue. Where If I sent a message to the DataRequestQueue MDB will process the message and send the response to DataReplyQueue. I have used Camel to send the message and receive the response. I have us

Re: InOut exchange pattern on Transactional JMS endpoint not working

2019-08-07 Thread Claus Ibsen
Hi You cannot do request/reply via reply queues with InOut and with transactions as its a chicken/egg situation. The message that is sent to the request queue (for req/reply) is not committed until the transaction is committed and therefore the received cannot "see" the message. On Wed, Aug 7, 20

Re: InOut exchange pattern on Transactional JMS endpoint not working

2019-08-07 Thread sujin sr
Thanks Claus Ibsen for the response. So If I process replyQueue via a separate route I am wondering about the below two points 1. How I can transfer requestMessage headers values to the replyMessage headers. 2. I want to get the replyMessages only send from my producer alone, how to listen on

http4 and x509HostnameVerifier

2019-08-07 Thread Riaan Annandale
Hi guys I'm trying to speak to a staging environment that uses self-signed certs. This means that when I try connect I get: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target As I run my camel app in

Re: InOut exchange pattern on Transactional JMS endpoint not working

2019-08-07 Thread sujin sr
Hi Claus Ibsen , Could you please provide some input on the previous queries? Thanks. On Wed, 7 Aug 2019 at 13:07, sujin sr wrote: > Thanks Claus Ibsen for the response. > > So If I process replyQueue via a separate route I am wondering about the > below two points > 1. How I can transfer

Re: http4 and x509HostnameVerifier

2019-08-07 Thread Zoran Regvart
Hi Riaan, I would take a different approach: to provide the additional trust anchor certificates in a Java keystore file, privided by a ConfigMap, and on startup check if the additional keystore file exists and either use that instead of the system keystore file or merge the two and configure Camel

RE: http4 and x509HostnameVerifier

2019-08-07 Thread Riaan Annandale
Hi Zoran Your advice was perfect. I imported the offending certificate and then started my camel instance with -Djavax.net.ssl.trustStore=src/main/resources/SSLCerts/cacerts Problem solved 😊 Thank you! -Original Message- From: Zoran Regvart Sent: Wednesday, 07 August 2019 13:38 To:

Help for use REGX subscribe to multiple topics.

2019-08-07 Thread Samir Anand
Hi, I am using camel-kafka version 2.23.1 for one of our requirement. But our team is facing one issue. I am trying to use the regular expression to subscribe to multiple topics. I am appending param (topicIsPattern=true) to endpoint uri, as per doc. But somehow that is not working. If I use reg

Persistent MQTT Client Message Lost

2019-08-07 Thread Michael Zaugg
We're having difficulties with persistent clients (using cleanSession=false). We would like to get messages that were sent while our client was disconnected. Steps to reproduce: 1. start route to create the initial subscription for the testclient from("mqtt:bar?subscribeTopicName=testtopic&cleanSe

Re: Help for use REGX subscribe to multiple topics.

2019-08-07 Thread Jan Bednář
Hi Samir, You can find example in this unit test https://github.com/apache/camel/blob/camel-2.23.x/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTopicIsPatternTest.java Dne 7.8.2019 v 15:21 Samir Anand napsal(a): Hi, I am using camel-kafka version 2.23.1 f

Re: Persistent MQTT Client Message Lost

2019-08-07 Thread Willem Jiang
Hi Can I know which version of Camel are you using? I just checked the code of camel-mqtt, there are some changes to fix the connection related issues. I doubt that the connection is not full released in your case. Can you try to stop the camel application instead of stop the camel route? Wille

Re: distributing files among clusters

2019-08-07 Thread arshad dar
Thanks for your response.I have around 50 routes and each routes is replicated on 5 nodes.The way you suggested isn't it possible that all the 50 files will be processed by one node while other 4 nodes will remain idle. On Wed, 7 Aug, 2019, 4:46 AM Farkas Lajos, wrote: > Hello, > > the simplest

Re: distributing files among clusters

2019-08-07 Thread Claus Ibsen
Hi If you have a copy of the Camel in Action 2nd edition book, then the concurrency chapter covers how to distribute and process files concurrently. On Fri, Aug 2, 2019 at 12:02 PM arshad dar wrote: > > Hi All, > > i have few camel routes which are reading from a directory say Samples. the > ca

Re: Persistent MQTT Client Message Lost

2019-08-07 Thread Michael Zaugg
Hi Willem It's camel version 2.24.0 We gracefully stopped the whole java process with the same result. "Sending PUBLISH to testclient" occurs before "Received SUBSCRIBE" according to Mosquitto's log: 1565245897: New client connected from 172.17.0.1 as testclient (p1, c0, k30). 1565245897: No wi