rpcdispatcherexceptiontest.java

来自「JGRoups源码」· Java 代码 · 共 78 行

package org.jgroups.blocks;

import junit.framework.TestCase;
import junit.framework.Test;
import junit.framework.TestSuite;
import org.jgroups.JChannel;
import org.jgroups.TimeoutException;
import org.jgroups.ChannelException;

import java.io.IOException;
import java.io.NotSerializableException;

/**
 * @author Bela Ban
 * @version $Id: RpcDispatcherExceptionTest.java,v 1.2 2006/05/12 09:56:27 belaban Exp $
 */
public class RpcDispatcherExceptionTest extends TestCase {
    RpcDispatcher disp;
    JChannel channel;

    protected void setUp() throws Exception {
        super.setUp();
        channel=new JChannel();
        disp=new RpcDispatcher(channel, null, null, this);
        channel.connect("demo");
    }

    protected void tearDown() throws Exception {
        super.tearDown();
        disp.stop();
        channel.close();
    }

    public void foo(Pojo p) {
        System.out.println(p.toString());
    }


    public void testUnserializableValue() {
        try {
            disp.callRemoteMethods(null, "foo", new Object[]{new Pojo()}, new Class[]{Pojo.class}, GroupRequest.GET_ALL, 5000);
            fail("this should have thrown an exception");
        }
        catch(Throwable t) {
            System.out.println("received an exception as expected: " + t);
            assertTrue(t instanceof RuntimeException);
            Throwable cause=t.getCause();
            assertTrue(cause instanceof NotSerializableException);
        }
    }

    public void testUnserializableValue2() {
        try {
            disp.callRemoteMethod(channel.getLocalAddress(), "foo", new Object[]{new Pojo()}, new Class[]{Pojo.class},
                                  GroupRequest.GET_ALL, 5000);
            fail("this should have thrown an exception");
        }
        catch(Throwable t) {
            System.out.println("received an exception as expected: " + t);
            assertTrue(t instanceof NotSerializableException);
        }
    }

    static class Pojo { // doesn't implement Serializable !
        int age; String name;
    }


    public static Test suite() {
        return new TestSuite(RpcDispatcherExceptionTest.class);
    }


    public static void main(String[] args) {
        junit.textui.TestRunner.run(RpcDispatcherExceptionTest.suite());
    }
}