1 17 package org.apache.servicemix.bpe; 18 19 import javax.jbi.messaging.ExchangeStatus; 20 import javax.jbi.messaging.MessageExchange; 21 import javax.xml.namespace.QName ; 22 23 import org.apache.servicemix.client.DefaultServiceMixClient; 24 import org.apache.servicemix.client.ServiceMixClient; 25 import org.apache.servicemix.jbi.jaxp.SourceTransformer; 26 import org.apache.servicemix.jbi.jaxp.StringSource; 27 import org.apache.servicemix.tck.SpringTestSupport; 28 import org.apache.xbean.spring.context.ClassPathXmlApplicationContext; 29 import org.springframework.context.support.AbstractXmlApplicationContext; 30 31 public class BPESpringComponentTest extends SpringTestSupport { 32 33 public void test() throws Exception { 34 ServiceMixClient client = new DefaultServiceMixClient(jbi); 35 MessageExchange me = client.createInOutExchange(); 36 me.setService(new QName ("urn:logicblaze:soa:loanbroker", "LoanBrokerService")); 37 me.setOperation(new QName ("getLoanQuote")); 38 me.getMessage("in").setContent(new StringSource("<getLoanQuoteRequest xmlns=\"urn:logicblaze:soa:loanbroker\"><ssn>1234341</ssn><amount>100000.0</amount><duration>12</duration></getLoanQuoteRequest>")); 39 long t0 = System.currentTimeMillis(); 40 client.sendSync(me); 41 long t1 = System.currentTimeMillis(); 42 if (me.getError() != null) { 43 throw me.getError(); 44 } 45 assertEquals(ExchangeStatus.ACTIVE, me.getStatus()); 46 String out = new SourceTransformer().contentToString(me.getMessage("out")); 47 System.err.println(out); 48 System.err.println("Time: " + (t1 - t0)); 49 client.done(me); 50 } 51 52 protected AbstractXmlApplicationContext createBeanFactory() { 53 return new ClassPathXmlApplicationContext("org/apache/servicemix/bpe/spring.xml"); 54 } 55 56 } 57 | Popular Tags |