houseloangateway.java

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

package houseloan;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.servicemix.components.util.TransformComponentSupport;

import javax.jbi.messaging.MessageExchange;
import javax.jbi.messaging.MessagingException;
import javax.jbi.messaging.NormalizedMessage;
import javax.xml.namespace.QName;

public class HouseLoanGateway extends TransformComponentSupport {

    private static final Log log = LogFactory.getLog(HouseLoanGateway.class); 

    protected boolean transform(MessageExchange exchange, NormalizedMessage in, NormalizedMessage out) throws MessagingException {
        log.info("Receiving lender gateway requesttttttttttttttttttt");

        int houseNumber = ((Integer) in.getProperty(Constants.HOUSE_NUMBER)).intValue();

        QName[] recipients;
        if (houseNumber==0) {
            recipients = new QName[] { new QName(Constants.LOANBROKER_NS, "bank0") };
        } else
        if (houseNumber==1) {
            recipients = new QName[] { new QName(Constants.LOANBROKER_NS, "bank1") };
        } else
        if (houseNumber==2) {
            recipients = new QName[] { new QName(Constants.LOANBROKER_NS, "bank2") };
        } else {
        recipients = new QName[] { new QName(Constants.LOANBROKER_NS, "bank3") };
        }
        out.setProperty(Constants.PROPERTY_RECIPIENTS, recipients);
        return true;
    }

}