diff options
Diffstat (limited to '')
-rw-r--r-- | sca-java-2.x/tags/2.0-Beta1-RC1/modules/host-corba-jse/src/test/java/org/apache/tuscany/sca/host/corba/testing/DefaultCorbaHostTestCase.java | 253 |
1 files changed, 0 insertions, 253 deletions
diff --git a/sca-java-2.x/tags/2.0-Beta1-RC1/modules/host-corba-jse/src/test/java/org/apache/tuscany/sca/host/corba/testing/DefaultCorbaHostTestCase.java b/sca-java-2.x/tags/2.0-Beta1-RC1/modules/host-corba-jse/src/test/java/org/apache/tuscany/sca/host/corba/testing/DefaultCorbaHostTestCase.java deleted file mode 100644 index 4a6a01bf97..0000000000 --- a/sca-java-2.x/tags/2.0-Beta1-RC1/modules/host-corba-jse/src/test/java/org/apache/tuscany/sca/host/corba/testing/DefaultCorbaHostTestCase.java +++ /dev/null @@ -1,253 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.tuscany.sca.host.corba.testing; - -import static junit.framework.Assert.assertEquals; -import static junit.framework.Assert.assertTrue; -import static junit.framework.Assert.fail; - -import java.net.ConnectException; -import java.net.Socket; - -import junit.framework.Assert; - -import org.apache.tuscany.sca.host.corba.CorbaHost; -import org.apache.tuscany.sca.host.corba.CorbaHostException; -import org.apache.tuscany.sca.host.corba.CorbaHostUtils; -import org.apache.tuscany.sca.host.corba.jse.DefaultCorbaHost; -import org.apache.tuscany.sca.host.corba.naming.TransientNameServer; -import org.apache.tuscany.sca.host.corba.naming.TransientNameService; -import org.apache.tuscany.sca.host.corba.testing.general.TestInterface; -import org.apache.tuscany.sca.host.corba.testing.general.TestInterfaceHelper; -import org.apache.tuscany.sca.host.corba.testing.servants.TestInterfaceServant; -import org.junit.AfterClass; -import org.junit.BeforeClass; -import org.junit.Ignore; -import org.junit.Test; - -/** - * General tests - */ -public class DefaultCorbaHostTestCase { - - private static final String LOCALHOST = "localhost"; - private static final int DEFAULT_PORT = 11100; // 1050; - - private static CorbaHost host; - - private static TransientNameServer server; - - @BeforeClass - public static void start() { - try { - server = new TransientNameServer(LOCALHOST, DEFAULT_PORT, TransientNameService.DEFAULT_SERVICE_NAME); - Thread t = server.start(); - if (t == null) { - fail("The naming server cannot be started"); - } - host = new DefaultCorbaHost(); - } catch (Throwable e) { - e.printStackTrace(); - fail(e.getMessage()); - } - } - - @AfterClass - public static void stop() { - server.stop(); - } - - /** - * Tests registering and lookup CORBA services - */ - @Test - public void test_registerServant() { - try { - String uri = CorbaHostUtils.createCorbanameURI(LOCALHOST, DEFAULT_PORT, "Nested/Test"); - TestInterface servant = new TestInterfaceServant(); - host.registerServant(uri, servant); - TestInterface ref = TestInterfaceHelper.narrow(host.lookup(uri)); - assertEquals(2, ref.getInt(2)); - } catch (Exception e) { - e.printStackTrace(); - fail(); - } - } - - /** - * Tests unregistering servants - */ - @Test - public void test_unregisterServant() { - try { - String objName = "Unregistering/Test"; - String uri = CorbaHostUtils.createCorbanameURI(LOCALHOST, DEFAULT_PORT, objName); - TestInterface servant = new TestInterfaceServant(); - - // creating and releasing using corbaname URI - host.registerServant(uri, servant); - host.unregisterServant(uri); - host.registerServant(uri, servant); - host.unregisterServant(uri); - } catch (Exception e) { - e.printStackTrace(); - fail(); - } - } - - /** - * Tests situation when name is already registered - */ - @Test - public void test_nameAlreadyRegistered() { - // test using URI - try { - TestInterface servant = new TestInterfaceServant(); - String uri = CorbaHostUtils.createCorbanameURI(LOCALHOST, DEFAULT_PORT, "AlreadyRegisteredTest2"); - host.registerServant(uri, servant); - host.registerServant(uri, servant); - fail(); - } catch (CorbaHostException e) { - assertTrue(e.getMessage().equals(CorbaHostException.BINDING_IN_USE)); - } catch (Exception e) { - e.printStackTrace(); - fail(); - } - } - - /** - * Tests getting non existing reference - */ - @Test - public void test_getNonExistingObject() { - // try to fetch object with corbaname URI - try { - host.lookup(CorbaHostUtils.createCorbanameURI("NonExistingOne", DEFAULT_PORT, LOCALHOST)); - fail(); - } catch (CorbaHostException e) { - // The message is JDK-specific - // assertTrue(e.getMessage().equals(CorbaHostException.NO_SUCH_OBJECT)); - } catch (Exception e) { - // e.printStackTrace(); - fail(); - } - } - - /** - * Tests unregistering non existing reference - */ - @Test - public void test_unregisterNonExistentObject() { - // test using URI - try { - String uri = CorbaHostUtils.createCorbanameURI(LOCALHOST, DEFAULT_PORT, "NonExistingReference1"); - host.unregisterServant(uri); - fail(); - } catch (CorbaHostException e) { - assertTrue(e.getMessage().equals(CorbaHostException.NO_SUCH_OBJECT)); - } catch (Exception e) { - e.printStackTrace(); - fail(); - } - } - - /** - * Tests registering under invalid host - */ - @Test - public void test_invalidHost() { - try { - String url = CorbaHostUtils.createCorbanameURI("not_" + LOCALHOST, DEFAULT_PORT, "Name"); - TestInterface servant = new TestInterfaceServant(); - host.registerServant(url, servant); - fail(); - } catch (CorbaHostException e) { - // Expected - } catch (Exception e) { - // e.printStackTrace(); - fail(e.getMessage()); - } - } - - /** - * Tests registering under invalid port - */ - @Test - public void test_invalidPort() { - try { - String url = CorbaHostUtils.createCorbanameURI(LOCALHOST, DEFAULT_PORT + 1, "Name"); - TestInterface servant = new TestInterfaceServant(); - host.registerServant(url, servant); - fail(); - } catch (CorbaHostException e) { - // Expected - } catch (Exception e) { - e.printStackTrace(); - fail(e.getMessage()); - } - } - - /** - * Tests registering under invalid name - */ - @Test - @Ignore("SUN JDK 6 is happy with all kind of names") - public void test_invalidBindingName() { - try { - TestInterface servant = new TestInterfaceServant(); - host.registerServant("---", servant); - fail(); - } catch (CorbaHostException e) { - assertTrue(e.getMessage().equals(CorbaHostException.WRONG_NAME)); - } catch (Exception e) { - e.printStackTrace(); - fail(); - } - } - - /** - * - */ - @Ignore - @Test - public void test_ensureORBStopped() { - try { - int innerORBPort = 11102; - TransientNameServer innerServer = - new TransientNameServer(LOCALHOST, innerORBPort, TransientNameService.DEFAULT_SERVICE_NAME); - innerServer.start(); - innerServer.stop(); - try { - Thread.sleep(500); - } catch (Exception e) { - } - Socket socket = new Socket(LOCALHOST, innerORBPort); - Assert.assertFalse(socket.isConnected()); - fail(); - } catch (Exception e) { - if (e instanceof ConnectException) { - assertTrue(true); - } else { - e.printStackTrace(); - } - } - } - -} |