WMQ + CamelBlueprintTestSupport

Hello, I was able to successfully configure Apache Camel 2.12 to listen to a WMQ queue. I am able to deploy it into Fuse 6.1 successfully and I get messages. I am trying to create some CamelBlueprintTestSupport tests and I run into the following error: Failed to create route .. because of Faile

Camel Kafka Component as a Consumer within a Route

Hello, I am trying to use the kafka component as a consumer from within a route. For instance, from("timer://foo?fixedRate=true&period=6") /* Use Kafka to consumer message */ .setHeader("kafka.OFFSET",constant("0"))

Re: WMQ + CamelBlueprintTestSupport

Hello, Thank you for the response. I tried this already and it did not work. I will continue to work on this to see if I can figure out what the issue is and will post if/once I solve this issue in case others run into the same issue. Thank You, sunil. -- View this message in context: http:

Re: Camel Kafka Component as a Consumer within a Route

Hello, Yes. Thank you. We are able to do this with PollEnrich. The following route is modified: from("timer://foo?fixedRate=true&period=1") .setBody().constant("test") .setHeader("kafka.OFFSET",constant("smallest"))

pollEnricher + Kafka + Aggregator

Hello, I am trying to use the pollEnrich to consume messages from a kafka server in the following manner: A "timer" based route runs periodically Use "pollEnrich" with an AggregatorStrategy to get as much messages from the topic until the pollEnricher expires. The issues is that the pollEnrich w

Re: pollEnricher + Kafka + Aggregator

Hello, Forgot to mention that I am using Camel 2.12 (Fuse 6.1). thanks, sunil. -- View this message in context: http://camel.465427.n5.nabble.com/pollEnricher-Kafka-Aggregator-tp5775433p5775434.html Sent from the Camel Development mailing list archive at Nabble.com.

PollEnrich + JPA + setCompletionFromBatchConsumer + aggregator

Hello, I am using Apache Camel 2.12 (Fuse 6.1). I am trying to use the JPA consumer to consume from a database at every given interval using a timer. I like to consume all of the records that match the search criteria using the aggregator. If the JPA consumer is a standalone route, I can use the

dataformat:// Component with JSON

Hello, I am trying to use the dataformat: component to unmarshal a JSON payload. The following code works: from("direct-vm:moxy-unmarshal-json") .unmarshal("jsonDataformat"); I want to use dataformat: component in the following manner: from("direct-vm:moxy-unmarshal-json") .to(

Re: WMQ + CamelBlueprintTestSupport

Hi Quinn, Sorry I did not see this comment. I configure the /etc folder within JBoss Fuse to provide this information. That part is working fine though. Thanks, Sunil. -- View this message in context: http://camel.465427.n5.nabble.com/WMQ-CamelBlueprintTestSupport-tp5774845p5776758.html Sen

Issues with Spring DSL with Splitter + Tokenizer + Header

Hello, I can do the following in Java DSL: split(header("something").tokenize("\n")).to("something"); But I cannot do the same in Blueprint/Spring DSL: ${header.something} I get the following error: Caused by: org.xml.sax.SAXParseException; cvc-complex-type.2.4.a: Invalid content was found st