duplextest.java

Xfire文件 用于开发web service 的一个开源工具 很好用的

package org.codehaus.xfire;


import org.codehaus.xfire.exchange.OutMessage;
import org.codehaus.xfire.test.AbstractXFireTest;
import org.codehaus.xfire.transport.Channel;
import org.codehaus.xfire.transport.local.LocalTransport;
import org.codehaus.xfire.util.jdom.JDOMEndpoint;
import org.codehaus.xfire.util.jdom.JDOMSerializer;
import org.jdom.Document;
import org.jdom.Element;

public class DuplexTest
    extends AbstractXFireTest
{
    public void testPeer1() throws Exception
    {
        LocalTransport transport = new LocalTransport();
        Channel channel1 = transport.createChannel("urn:xfire:local://Peer1");
        channel1.open();
        
        Channel channel2 = transport.createChannel("urn:xfire:local://Peer2");
        JDOMEndpoint endpoint = new JDOMEndpoint();
        channel2.setEndpoint(endpoint);

        // Document to send
        Element root = new Element("root");
        root.addContent("hello");
        Document doc = new Document(root);
        
        MessageContext context = new MessageContext();
        
        OutMessage msg = new OutMessage("urn:xfire:local://Peer2");
        msg.setSerializer(new JDOMSerializer());
        msg.setBody(doc);
        
        channel1.send(context, msg);
        channel1.send(context, msg);
        
        for (int i = 0; i < 10000; i++)
        {
            Thread.sleep(50);
            if (endpoint.getCount() == 2) break;
        }
        
        channel1.close();
        channel2.close();
        
        assertEquals(2, endpoint.getCount());
    }
}