Mailing-List: contact camel-user-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: camel-user@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of gert.vanthienen@skynet.be
 designates 195.238.6.178 as permitted sender)
Message-ID: <48328C54.2030307@skynet.be>
Date: Tue, 20 May 2008 10:31:16 +0200
From: Gert Vanthienen <gert.vanthienen@skynet.be>
User-Agent: Thunderbird 2.0.0.14 (X11/20080505)
MIME-Version: 1.0
To: camel-user@activemq.apache.org
Subject: Re: what is the difference between requestBodyAndHeader and
 sendBodyAndHeader
 method ?
References: <17335200.post@talk.nabble.com>
In-Reply-To: <17335200.post@talk.nabble.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit

J.H.Cha,

The only difference I see when I look at the code, it the message 
ExchangePattern.  requestBodyAndHeader() explicitly sets the pattern to 
InOut, while the sendBodyAndHeader() just leaves the default (InOnly).  
Not sure why this causes a problem in your case though, I would even 
think that InOut would be a more correct representation...

I would guess that the InOut pattern causes the http: endpoint to wait 
on a reply from the jetty: endpoint, but I'm not sure why that doesn't 
happen.  What version of Camel are you using?  To determine what's going 
on here, could you try replacing your http/jetty endpoints with a 
direct:b or something? 

Regards,

Gert


jhcha wrote:
> When I tested two methods  requestBodyAndHeader and sendBodyAndHeader in my
> test source,
> I found the very curious result. 
>
> sendBodyAndHeader  returns ok, but requestBodyAndHeader does not return, and
> hangs...
>
> two methods have the same(?) input parameters and very similar comments.. 
> (Is it different things, endpoint and endpointUri ? ) 
>
> Object requestBodyAndHeader(String endpoint, Object body, String header,
> Object headerValue)
>           Send the body to an endpoint returning any result output body
>           
> Object sendBodyAndHeader(String endpointUri, Object body, String header,
> Object headerValue)
>           Sends the body to an endpoint with a specified header and header
> value
>
> Maybe I should not use requestBodyAndHeader with "direct" end point.
>
> but I need to know the accurate reason for that. 
>
> Would you explain me what is the difference of the two methods, 
> and the correct usage case ?
>
> Thank you.
>
> J. H. Cha
>
> the below source is my test code.
> =============================
>       
>           
> import org.apache.camel.CamelContext;
> import org.apache.camel.CamelTemplate;
> import org.apache.camel.Endpoint;
> import org.apache.camel.Exchange;
> import org.apache.camel.Processor;
> import org.apache.camel.builder.RouteBuilder;
> import org.apache.camel.impl.DefaultCamelContext;
> import org.apache.camel.impl.DefaultExchange;
> import org.apache.camel.util.ExchangeHelper;
> import org.apache.log4j.Logger;
>
> public class JettyRequestTest extends Thread {
>
> 	private static final Logger logger =
> Logger.getLogger(JettyRequestTest.class);
>
> 	private static int threads = 1;
>
> 	
> 	public static void main(String[] args) throws Exception {
>
> 		for (int i = 0; i < threads; i++) {
> 			JettyRequestTest client = new JettyRequestTest();
> 			client.start();
> 		}
> 	}
>
> 	@Override
> 	public void run() {
> 		try {
> 			testJettyConsumerEndpoint();
> 		} catch (Exception e) {
> 			logger.fatal("testJmsSpeed fail", e);
> 		}
> 	}
>
> 	public void testJettyConsumerEndpoint() throws Exception {
> 		try {
> 			CamelContext ctx = new DefaultCamelContext();
>
> 			RouteBuilder builder = new ServerRoutes();
> 			ctx.addRoutes(builder);
>
> 			ctx.start();
>
> 			CamelTemplate<DefaultExchange> template = new
> CamelTemplate<DefaultExchange>(ctx);
>
> 			String body = "<hello>world!</hello>";
>
> 			Object result = template.sendBodyAndHeader("direct:start", body,
> "Content-Type",  "application/xml");
> 			Exchange exchange = new DefaultExchange(ctx);
> 			String response = ExchangeHelper.convertToType(exchange, String.class,
> result);
> 			logger.info("response : [" + response + "]");
> 					
> 			// the below line meet hang !!!!								
> 			template.requestBodyAndHeader("direct:start",	body, "Content-Type",
> "application/xml");
>
>
> 			ctx.stop();
> 		} catch (Throwable e) {
> 			if (logger.isEnabledFor(org.apache.log4j.Level.ERROR)) {
> 				logger.error("testJettyConsumerEndpoint()", e);
> 			}
>
> 			e.printStackTrace();
> 		}
> 	}
> }
>
> class ServerRoutes extends RouteBuilder {
> 	@Override
> 	public void configure() throws Exception {
> 		Processor proc = new Processor() {
> 			public void process(Exchange exchange) throws Exception {
> 				String request = exchange.getIn().getBody(String.class);
> 				exchange.getOut(true).setBody(request + " >> processed");
> 			}
> 		};
>
> 		from("jetty:http://localhost:8080/hello").process(proc);
>
> 		from("direct:start").to("http://localhost:8080/hello");
> 	}
> }
>           
>