Return-Path: 
 <users-return-8854-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 47895 invoked from network); 30 Apr 2007 17:12:25 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 30 Apr 2007 17:12:25 -0000
Received: (qmail 26603 invoked by uid 500); 30 Apr 2007 17:12:31 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 26361 invoked by uid 500); 30 Apr 2007 17:12:30 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 26352 invoked by uid 99); 30 Apr 2007 17:12:30 -0000
Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 30 Apr 2007 10:12:30 -0700
X-ASF-Spam-Status: No, hits=-0.0 required=10.0
	tests=SPF_HELO_PASS,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (herse.apache.org: domain of lists@nabble.com designates
 72.21.53.35 as permitted sender)
Received: from [72.21.53.35] (HELO talk.nabble.com) (72.21.53.35)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 30 Apr 2007 10:12:23 -0700
Received: from [72.21.53.38] (helo=jubjub.nabble.com)
	by talk.nabble.com with esmtp (Exim 4.50)
	id 1HiZPu-0004JY-Rn
	for users@activemq.apache.org; Mon, 30 Apr 2007 10:12:02 -0700
Message-ID: <10257108.post@talk.nabble.com>
Date: Mon, 30 Apr 2007 10:12:02 -0700 (PDT)
From: "dr.jeff" <jlansing@systechnologies.com>
To: users@activemq.apache.org
Subject: Re: [camel] using camel spring container
In-Reply-To: <ec6e67fd0704300915y5945944ep2f0ba4fa5fb478e7@mail.gmail.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: jlansing@systechnologies.com
References: <10237598.post@talk.nabble.com>
 <ec6e67fd0704300224k75d70092r91d932e9b0d26bda@mail.gmail.com>
 <ec6e67fd0704300309l5ad63507reccbbf2769857e@mail.gmail.com>
 <ec6e67fd0704300359x462e9b14x85fa3f8c8e5315c4@mail.gmail.com>
 <10255927.post@talk.nabble.com>
 <ec6e67fd0704300915y5945944ep2f0ba4fa5fb478e7@mail.gmail.com>
X-Virus-Checked: Checked by ClamAV on apache.org


My xml looks like this:

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="
       http://www.springframework.org/schema/beans ./spring-beans-2.0.xsd
       http://activemq.apache.org/camel/schema/camel-1.0.xsd ./camel-1.0.xsd
">
  <bean id="stringProcessor" class="test.StringProcessor"
init-method="init"/>
  <camelContext id="camel"
xmlns="http://activemq.apache.org/camel/schema/camel-1.0.xsd">
    <routes>
      <route>
        <from uri="direct:outgoing"/>
        <process ref="#stringProcessor"/>
      </route>
    </routes>
  </camelContext>
</beans>

StringProcessor.java looks like this:

public class StringProcessor implements Processor<Exchange> {

	public StringProcessor() {
	}
	public void init() {
		System.out.println("new string processor");
	}
	public void process(Exchange e) {
		System.out.println("process: " + e.getIn());
	}
}

I call it like this:

	public TestSimpleXml(String ctxFile) {
		ctx = new ClassPathXmlApplicationContext(ctxFile);
		try {
			container = (CamelContext) ctx.getBean("camel");
			Endpoint<Exchange> endpoint = container.getEndpoint("direct:incoming");
			Exchange exchange = endpoint.createExchange();
	        Message m = exchange.getIn();
	        m.setBody("test message");
	        Producer<Exchange> producer = endpoint.createProducer();
	        producer.process(exchange);
	        Thread.sleep(5000); //let queues clean out
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

I see that the init() method of StringProcessor is being called. I expect to
see the message reach the process() method, but I do not.

This seems so simple. Am I still missing something?


James.Strachan wrote:
> 
> 
> ...
> 
> and see the test case work
> 
> -- 
> James
> -------
> http://macstrac.blogspot.com/
> 
> 

-- 
View this message in context: http://www.nabble.com/-camel--using-camel-spring-container-tf3663875s2354.html#a10257108
Sent from the ActiveMQ - User mailing list archive at Nabble.com.