Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (nike.apache.org: domain of willem.jiang@gmail.com
 designates 209.85.160.45 as permitted sender)
Message-ID: <50133EF9.7080006@gmail.com>
Date: Sat, 28 Jul 2012 09:23:05 +0800
From: Willem Jiang <willem.jiang@gmail.com>
User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10.7;
 rv:14.0) Gecko/20120713 Thunderbird/14.0
MIME-Version: 1.0
To: users@camel.apache.org
Subject: Re: How to invoke CXF webservice from processor bean
References: <1342748062799-5716272.post@n5.nabble.com>
 <CA+QaCWKhh4dd=D7zbzEVT+6=Lo2639tZh2DJKyCxHrh2v4Jg6Q@mail.gmail.com>
 <1343427476566-5716569.post@n5.nabble.com>
In-Reply-To: <1343427476566-5716569.post@n5.nabble.com>
Content-Type: text/plain; charset=UTF-8; format=flowed
Content-Transfer-Encoding: 7bit

Yeah, this example is setting the right headers on the message which is 
passed by the exchange.

On Sat Jul 28 06:17:56 2012, ychawla wrote:
> I have something like this working in a unit test.  Maybe you can try
> something similar:
>
> 	public static final String CXF_OPERATION_NAME = "operation";
> 	public static final String CXF_OPERATION_NAMESPACE = "http://opNamespace";
>
> 	@Test
> 	@DirtiesContext
>      public void myTest() throws Exception
>      {
>
>      	String
> pathToFileForExchangeBody="src/test/resources/xmlInstances/mypayload.xml";
>      	
>      	Exchange senderExchange = createCXFExchange(pathToFileForExchangeBody);
> 	
> 	//Send the one-way exchange.  Using template.send will send a one way
> message
>         Exchange returnExchange =
> template.send("cxf:bean:mybean?dataFormat=PAYLOAD&loggingFeatureEnabled=true&synchronous=true",
> senderExchange);
> 		
> 		//Use getException to see if we received an exception
> 		if (returnExchange.getException() != null)
> 		{	
> 			throw new Exception(returnExchange.getException());
> 		}	
>      }
>
>      private Exchange createCXFExchange(String pathToFileForExchangeBody)
>      {
>      	//Create a new exchange
>      	Exchange senderExchange = new DefaultExchange(context);
> 		
> 	//Set the operation name and operation namespace for the CXF exchange
> 	    senderExchange.getIn().setHeader(CxfConstants.OPERATION_NAME,
> CXF_OPERATION_NAME);
> 	    senderExchange.getIn().setHeader(CxfConstants.OPERATION_NAMESPACE,
> CXF_OPERATION_NAMESPACE);
> 	
> 	    //Read the icotns request file from the file system, this one has no
> endpoint to route to
> 	    File inputFile = new File(pathToFileForExchangeBody);
> 	
> 	    assertTrue(inputFile.exists());
> 	    log.debug("Does input file exist: " + inputFile.exists());
> 	
> 	    //Set it as the message message body
> 	    senderExchange.getIn().setBody(inputFile);
> 	
> 	    return senderExchange;
>
>      }
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/How-to-invoke-CXF-webservice-from-processor-bean-tp5716272p5716569.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>


--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog:    http://willemjiang.blogspot.com (English)
         http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang