rpcdispatcherunicastmethodexceptiontest.java

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

package org.jgroups.blocks;

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

/**
 * @author Bela Ban
 * @version $Id: RpcDispatcherUnicastMethodExceptionTest.java,v 1.3 2006/04/30 13:45:54 belaban Exp $
 */
public class RpcDispatcherUnicastMethodExceptionTest 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 Object foo() {
        System.out.println("-- foo()");
        return "foo(): OK";
    }

    public Object bar() throws Exception {
        System.out.println("-- bar()");
        throw new TimeoutException("this is an exception");
    }

    public Object foobar() {
        System.out.println("-- foobar()");
        throw new IllegalArgumentException("bla bla bla from foobar");
    }

    public Object foofoobar() {
        System.out.println("-- foofoobar()");
        throw new AssertionError("bla bla bla from foofoobar");
    }

    public void fooWithThrowable() throws Throwable {
        System.out.println("-- fooWithThrowable()");
        throw new Throwable("this is an exception");
    }



    public void testMethodWithoutException() throws Throwable {
        Object retval=disp.callRemoteMethod(channel.getLocalAddress(), "foo", null, (Class[])null, GroupRequest.GET_ALL, 5000);
        System.out.println("retval: " + retval);
        assertNotNull(retval);
    }



    public void testMethodWithException() throws ChannelException {
        try {
            Object retval=disp.callRemoteMethod(channel.getLocalAddress(), "bar", null, (Class[])null, GroupRequest.GET_ALL, 5000);
            System.out.println("retval: " + retval);
            fail("we should not get here; bar() should throw an exception");
        }
        catch(Throwable e) {
            System.out.println("caught exception (" + e + ") - as expected");
            assertTrue(e instanceof TimeoutException);
        }
    }

    public void testMethodWithException2() throws ChannelException {
        try {
            Object retval=disp.callRemoteMethod(channel.getLocalAddress(), "foobar", null, (Class[])null, GroupRequest.GET_ALL, 5000);
            System.out.println("retval: " + retval);
            fail("we should not get here; foobar() should throw an exception");
        }
        catch(Throwable e) {
            System.out.println("caught exception (" + e + ") - as expected");
            assertTrue(e instanceof IllegalArgumentException);
        }
    }

    public void testMethodWithError() throws ChannelException {
        try {
            Object retval=disp.callRemoteMethod(channel.getLocalAddress(), "foofoobar", null, (Class[])null, GroupRequest.GET_ALL, 5000);
            System.out.println("retval: " + retval);
            fail("we should not get here; foofoobar() should throw an exception");
        }
        catch(Throwable e) {
            System.out.println("caught exception (" + e + ") - as expected");
            assertTrue(e instanceof AssertionError);
        }
    }

    public void testMethodWithThrowable() throws ChannelException {
        try {
            Object retval=disp.callRemoteMethod(channel.getLocalAddress(), "fooWithThrowable", null, (Class[])null, GroupRequest.GET_ALL, 5000);
            System.out.println("retval: " + retval);
            fail("we should not get here; foofoobar() should throw an exception");
        }
        catch(Throwable e) {
            System.out.println("caught exception (" + e + ") - as expected");
            assertTrue(e instanceof Throwable);
        }
    }


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


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