loanbrokerclient.java

基于eclipse环境下开发的Synapse例程

package sample.rpcclient;

import javax.xml.namespace.QName;

import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

import sample.data.Quote;


public class LoanBrokerClient {
	
	public static int getHouseNumber(String name) throws AxisFault{
		
        RPCServiceClient serviceClient = new RPCServiceClient();

        Options options = serviceClient.getOptions();
        
        EndpointReference targetEPR = new EndpointReference("http://localhost:8080/axis2/services/HouseLoanAgency");
        options.setTo(targetEPR);

        QName opName = new QName("http://service.sample", "getHouseNumber");
        

        Class[] returnTypes = new Class[] { Integer.class };
        

        Object[] opArgs = new Object[] { name };

        Object[] response = serviceClient.invokeBlocking(opName,opArgs,returnTypes);
        
        Integer houseNumber = (Integer) response[0];;
        
        if (houseNumber == null) {
            System.out.println("HouseLoanAgency didn't initialize!");
            return -1;
        }
        
        
        return houseNumber.intValue();
		
	}
	
	
	public static Quote getQuote(int houseNumber) throws AxisFault{
		
        RPCServiceClient serviceClient = new RPCServiceClient();

        Options options = serviceClient.getOptions();
        
        EndpointReference targetEPR = new EndpointReference("http://localhost:8080/axis2/services/BankService0");
        options.setTo(targetEPR);

        QName opName = new QName("http://service.sample", "getQuote");
        
        Class[] returnTypes = new Class[] { Quote.class };
        

        Object[] opArgs = new Object[] { new Integer(houseNumber) };

        Object[] response = serviceClient.invokeBlocking(opName,opArgs,returnTypes);
        
        Quote quote = (Quote) response[0];;
        
        if (quote == null) {
            System.out.println("Bank didn't initialize!");
            return null;
        }
        
        
        return quote;
		
	}


    public static void main(String[] args1) throws AxisFault {
        
    	String name = "Wang Wu";
    	int houseNumber = getHouseNumber(name);
    	Quote quote = getQuote(houseNumber);
    	
    	System.out.println("Name="+name);
        System.out.println("Bank Name="+quote.getBankName());
        System.out.println("first Paid Ratio="+quote.getFirstPaidRatio());
        System.out.println("rate="+quote.getRate());
        
    }
}