Camel jms - In Out Pattern

Hi, iam new to camel,Im trying to implement a synchronous request-reply mechanism using camel component. I have 2 wmq queues *1. requestQuee - application will send requests to this queue 2. responseQueue - application will have to listen & receive response from this queue * /

Re: ConcurrentModificationException during route listing

ConcurrentModificationException happens to be due the fact that you are trying to modify the collection whereas you are traversing it. It's hard to help you unless we know some details of design of your route. If you can provide details, we can give it a shot.. -- View this message in context:

Re: Camel jms - In Out Pattern

Hi, You don't have to send message to the response queue. Camel will create a temporary response queue for you: from("jms:foo").setBody().constant("myresponse"); ... String response = producerTemplate.requestBody("jms:foo", "body", String.class); assertThat(response).isEqualTo("myresponse

Re: none of the policy alternatives can be satisfied in camel

Solved it by disabling the cxf policies... -- View this message in context: http://camel.465427.n5.nabble.com/none-of-the-policy-alternatives-can-be-satisfied-in-camel-tp5781795p5782742.html Sent from the Camel - Users mailing list archive at Nabble.com.

Default dynamic endpoint

Hi, Is it possible to createEndpoint only one in a context, and not as many requests, dynamically? eg: public void configure() { from("direct:a"). .setHeader("host", constant("smtp.gmail.com")).setBody(constant("b

Re: Camel jms - In Out Pattern

The third party provider will give response only in their response quee, thats why i set replyTo as their response queue name.(instead of temp queue), >From queue console i have observed that while configuring request response basically i have 2 queues from third party.one for sending request an

Cache component dependency causes tests to fail

Hi, I am using Camel with Spring Boot. I would like to use Camel cache-component. But simply adding cache component dependency org.apache.camel camel-cache 2.17.1 to pom.xml causes all tests to fail with following: java.lang.NoClassDefFoundError: Could not initialize class org.

Re: Kafka consumer issue in Camel 2.17

Could be different things. If I understand correctly consuming with 3 threads, each with their own topic, but probably with the same groupId goed fine, but when reading with 4 threads, each with their own topic you see an error? How long before you see the error? Maybe you have a time-out because e

camel-bindy not binding well when first column value is null

I have issues when first column value in a row is null. I have something like this:@CsvRecord(separator = "\\t", skipFirstLine = true)public class Inventory {@DataField(pos = 1, required=false)private String vendor; @DataField(pos = 2, required=false)private String sku;@DataField

Camel jms Request reply -scenario with separate queues for request and response

Hi Guys, I have 2 queues provided by third party provider 1.request queue, 2.reply queue using camel jms i will send request to request queue, so third party provider will push respective response to response queue. I would to make these calls synchronous. so for each request send to request qu

RE: Camel jms Request reply -scenario with separate queues for request and response

> I have 2 queues provided by third party provider 1.request queue, 2.reply > queue > > using camel jms i will send request to request queue, so third party provider > will push respective response to response queue. Ok. > I would to make these calls synchronous. so for each request send to > r

Re: mock http endpoint and retrieving value form properties file

Deepak - Where do you define the bean so Camel can find it? Normally, I’d put the bean in another Spring XML file (in src/test/resources/META-INF/spring for symmetry), and then change the application context such that it will load both Spring XML files. protected AbstractApplicationContext cre

How Can I Get the Camel Content Enricher to Process an Exchange from a REST Call?

I'm building a sample implementation that routes orders to an order management system. Inbound to the route is an exchange with two identifiers, one for the customer ID and one for the catalog item ID. I then transform the body the inbound exchange to my Order domain object. My goal is then to call

Re: Upgrade from 2.13.2 to 2.15.x has JMX bugs

Yes I have been using jconsole to try to piece together what the getDescription() used to provide but have not found all the answers. What the route.getDescription() used to provide in the 'processor' part was the 'to' route. E.g. where is the data going next and that is what the app really cares

Re: Camel jms - In Out Pattern

It looks like the other system isn’t setting the JMSCorrelationID, so the route is timing-out waiting for a response with that correlation ID. Have you tried setting replyToType=Exclusive? You can see the details in the camel-jms docs (http://camel.apache.org/jms.html

FW: Meaning of Exchange Property CamelFailureHandled

Hi Camel friends, Can anybody explain the meaning of the Exchange Property "CamelFailureHandled"? Especially, what's the difference to "CamelExceptionHandled" and "CamelErrorHandlerHandled"? I don't know, if it's a bug, but I found the following method in RedeliveryErrorHandler ( 2.16.2), whic

zookeeper route policy failover not working

Hi I am trying to use the zookeeper route policy for failover and it does not work as I would expect. Here’s an example route. ZooKeeperRoutePolicy policy = new ZooKeeperRoutePolicy("zookeeper://zookeeperHost/myapp/myroute", 1); from("quartz2:start").routePolicy(policy).log(“hello world”); I r