Re: SEDA with Aggregation

2016-10-24 Thread Vince Iglehart
That is helpful. With the completionTimeout() I would like to group messages coming in through the webservice so that RouteB is not called multiple times. For example if there are 500 messages with the same payload coming in through the webservice, I would like to aggregate all of them into 1 m

SEDA with Aggregation

2016-10-21 Thread Vince Iglehart
Hello, I have some questions on how the SEDA component operates. I am using Camel 2.17.3 in a non clustered environment. I have a scenario where I need to 1. Accept multiple incoming messages using a webservice 2. Aggregate messages using the $body of the message 3. After a lapse of 3 seconds, c

Re: Installing Camel-SQL - Unable to resolve javax.mail

2016-08-11 Thread Vince Iglehart
I wanted to give an update to this issue in case it might help someone else. I was able to resolve this issue thanks to Ranx. I upgraded to Camel 2.17.3 and the problem was resolved. Cheers -- View this message in context: http://camel.465427.n5.nabble.com/Installing-Camel-SQL-Unable-to-reso

Re: Installing Camel-SQL - Unable to resolve javax.mail

2016-08-09 Thread Vince Iglehart
I'm not sure if I understand exactly what your saying. Are you thinking the java packaging structure for objects inside javax.mail component may have changed from Java 1.4 to 1.5? When I look at the dependencies in the features.xml located at https://repo1.maven.org/maven2/org/apache/camel/kara

Re: Installing Camel-SQL - Unable to resolve javax.mail

2016-08-09 Thread Vince Iglehart
I agree with your assessment. However, the part that I don't understand is how it is missing. When I run the exports command from Karaf, this is what I get. I read this to say that javax.mail 1.5 is available. karaf@root()> exports | grep javax.mail com.sun.mail.handlers

Installing Camel-SQL - Unable to resolve javax.mail

2016-08-09 Thread Vince Iglehart
Hello, I am using Karaf 4.0.5. I am attempting to install feature camel-sql. When I attempt the install I receive the following error message: Error executing command: Unable to resolve javax.mail/1.4.5: missing requirement [javax.mail/1.4.5] osgi.wiring.package; filter:="(&(osgi.wiring.package

SQL Batch Consumer

2016-07-27 Thread Vince Iglehart
Hello, I have a route with batch consumer that I want to execute manually. The route will read information using a SQL statement, aggregate the result rows by ticket_nbr, and force complete each aggregated group after all the rows have been aggregated. Here is what I have so far: from("sql:class

Re: Camel/Karaf Resource - XSLT File Not Found

2016-07-12 Thread Vince Iglehart
I figured out the problem. I was using a class that implements BundleActivator to initialize the Camel context. However, I needed to use a blueprint.xml file to setup the Camel Context. I read on another post that using Blueprint sets up additional configuration necessary for resources to be fou

Camel/Karaf Resource for XSLT

2016-07-12 Thread Vince Iglehart
Hello, I am deploying a Camel 2.17.1 integration to Karaf 4.0.5. I run into the following error when attempting to perform a bundle:install - Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: xslt://xslt/speed.xslt?saxon=true due to: java.io.FileNotFoundExc

Aggregation Completion Criteria

2016-07-05 Thread Vince Iglehart
I need some assistance to make sure I'm on the right track. I think I'm very close, but I have a couple of missing pieces. I have the following SQL statement: select ticket_date, ticket_nbr, line_nbr, item_desc, quantity from tickets I want to group these rows by ticket date, ticket nbr, and l

Re: SQL Component with Batch Aggregation

2016-06-30 Thread Vince Iglehart
The SQL query is bringing back multiple groups. In other words, there are multiple line items for multiple tickets coming back from the databases. My understanding is the that the built in aggregator for the splitter puts all messages into one group. Therefore I don't think this pattern would w

SQL Component Data Types

2016-06-28 Thread Vince Iglehart
Hello, I want to know how I can tell which data types are being returned when I use a SQL component. For example, in a processor, I have the following snippet: Map lineItem = (Map ) exchange.getIn().getBody(); ??? customerCode = (???) lineItem.get("CUSTOMER_CODE"); How do I know which ty

Re: SQL Component with Batch Aggregation

2016-06-28 Thread Vince Iglehart
Bump Specifically I need help with the completionFromBatchConsumer() logic. In other words, how do I modify my SQL component to turn it into a batch consumer? -- View this message in context: http://camel.465427.n5.nabble.com/SQL-Component-with-Batch-Aggregation-tp5784462p5784499.html Sent

SQL Component with Batch Aggregation

2016-06-27 Thread Vince Iglehart
Hello, I need some help with an integration involving SQL batch processing and aggregation. The integration will be executed on demand by an end user. It will retrieve line items from a database, aggregate the line items by ticket nbr, and publish each ticket to web service. After the ticket is p

RE: HTTPS Component with SMTP Mail

2016-06-02 Thread Vince Iglehart
Stephan, Adding .removeHeaders("*") fixed the problem. It works great! Being new to Camel, I guess this is a "gotcha". Thanks for your help. -- View this message in context: http://camel.465427.n5.nabble.com/HTTPS-Component-with-SMTP-Mail-tp5783362p5783392.html Sent from the Camel - Users ma

HTTPS Component with SMTP Mail

2016-06-01 Thread Vince Iglehart
Hello, I am developing an integration that reads from an https4 url and sends the response to an SMTP endpoint. However the SMTP endpoint never receives the response. Here is my route definition. from("timer:fire?period=1") .to("https4://") .convertBodyTo(String.class).to("lo

Java Utility Expression

2014-08-20 Thread Vince Iglehart
Hello All, I am new to the Camel world and need some help on creating expressions. I have the following route defined using Java DSL. from("direct:jde") .setHeader("FMZ57FMR", simple("${body.fuelDistribution.quantity}")) .setHeader("FMZ57ST", simple("${body.fuelDistribution.sourceTank.state}"