1 22 package org.objectweb.petals.kernel.registry.jndi; 23 24 import java.io.IOException ; 25 26 import javax.naming.NamingException ; 27 28 import junit.framework.TestCase; 29 30 import org.objectweb.petals.kernel.registry.msg.request.FullUpdateRequest; 31 import org.objectweb.petals.kernel.registry.msg.request.PingRequest; 32 33 38 public class JNDIConnectionTest extends TestCase { 39 40 public void testSend() throws NamingException , IOException , 41 InterruptedException { 42 int port = 8765; 43 ServerSocketThread serverSocketThread = new ServerSocketThread(port, 44 "127.0.0.1"); 45 serverSocketThread.start(); 46 JNDIConnection jndiConnection = new JNDIConnection(port, "127.0.0.1"); 47 PingRequest pingRequest = new PingRequest(); 48 Object out = jndiConnection.send(pingRequest); 49 serverSocketThread.terminate(); 50 assertEquals(out, "test"); 51 } 52 53 public void testSendException() throws NamingException , IOException , 54 InterruptedException { 55 int port = 9876; 56 ServerSocketThread serverSocketThread = new ServerSocketThread(port, 57 "127.0.0.1"); 58 serverSocketThread.start(); 59 JNDIConnection jndiConnection = new JNDIConnection(port, "127.0.0.1"); 60 FullUpdateRequest electMasterRequest = new FullUpdateRequest(0, 0); 61 try { 62 jndiConnection.send(electMasterRequest); 63 fail(); 64 } catch (Exception e) { 65 66 } 67 serverSocketThread.terminate(); 68 } 69 } 70 | Popular Tags |