Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of seanmckaybeck@gmail.com
 designates 74.125.83.49 as permitted sender)
MIME-Version: 1.0
In-Reply-To: <51C4BB73.6030304@gmail.com>
References: 
 <CALP6eeahtW10VE4RB=xNMkRHVUYY6tLFrFMOZVifpKicWw_yeQ@mail.gmail.com>
	<CAGB5yNnL6ZArt6Dq2enkQCup6DwnuQe4ZfagDH401OPCe6gcmQ@mail.gmail.com>
	<CALP6eeYEsGfM+HgyToT9VK6ERhanA5Py01AktWQX7PqFaZpk-A@mail.gmail.com>
	<CALP6eeZHSc_OpPmAY9Zh0QMJY+o8AC04bNYyJsd8OCn4aYizpw@mail.gmail.com>
	<51C49A7B.90305@gmail.com>
	<CALP6eea91B88wtP1Nn6A=kkKEB9yZfJ_ypP0rKgo03X8G5cLbg@mail.gmail.com>
	<CALP6eeYTvqenks=oRcKFUOzGfOxqHtbdVrVrTqXziSULtX2Hug@mail.gmail.com>
	<CALP6eeZnYFHtcGYQB-6sAeJEtu8C66+wjESX=DpFiEv0=t05ug@mail.gmail.com>
	<51C4BB73.6030304@gmail.com>
Date: Tue, 25 Jun 2013 14:46:20 -0600
Message-ID: 
 <CALP6eebg==1aMZOprBqDnZTgPPM+XHq8Jm=tuR+qXvRuytM1wg@mail.gmail.com>
Subject: Re: How to start a process with Camel?
From: Sean Beck <seanmckaybeck@gmail.com>
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=001a11c275a01bc28804e0009f9d

--001a11c275a01bc28804e0009f9d
Content-Type: text/plain; charset=ISO-8859-1

So I have some code I've tried writing and I think it solves the problem. I
just want to check to make sure I'm not goofing anything up. Also, in
AggregationStrategy.aggregate() what exchange should I return from what I
have?

public static void main(String args[]) {
         CamelContext c = new DefaultCamelContext();
         ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");
         context.addComponent("jms",
JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
         context.addRoutes(new RouteBuilder() {
             public void configure() {
                 from("jms:analytics.camelqueue").aggregate(new
MyAggregationStrategy()).header("subject").completionSize(2).to("exec://FILEPATH?args=");
             }
         });
         context.start();
     }

     private static class MyAggregationStrategy implements AggregationStrategy {

         public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
             if (oldExchange == null)
                 return newExchange;
             // and here is where combo stuff goes
             String oldBody = oldExchange.getIn().getBody(String.class);
             String newBody = newExchange.getIn().getBody(String.class);
             boolean oldSet = oldBody.contains("set");
             boolean newSet = newBody.contains("set");
             boolean oldFlow = oldBody.contains("flow");
             boolean newFlow = newBody.contains("flow");
             if ( (oldSet && newFlow) || (oldFlow && newSet) ) {
                 //they match so start extractor then return
             }
             else {
                 // no match so do something....
             }

--001a11c275a01bc28804e0009f9d--