diff --git a/apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTimeoutTest.java b/apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTimeoutTest.java
index 249142c3f01b5b36e8c2eaf417663ba8b3f4ecee..3e671a850007ced1bf99eefe4555297582212e17 100644
--- a/apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTimeoutTest.java
+++ b/apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTimeoutTest.java
@@ -30,9 +30,7 @@ public class ConnectTimeoutTest  extends TestCase {
         I2PAppContext context = I2PAppContext.getGlobalContext();
         _log = context.logManager().getLog(ConnectTest.class);
         _log.debug("creating server dest");
-        try {
-            _serverDest = I2PClientFactory.createClient().createDestination(new ByteArrayOutputStream());
-        } catch (Exception e) {}
+        _serverDest = I2PClientFactory.createClient().createDestination(new ByteArrayOutputStream());
         _log.debug("creating client session");
         _client = createSession();
         _log.debug("running client");
@@ -75,20 +73,15 @@ public class ConnectTimeoutTest  extends TestCase {
         
     }
     
-    private I2PSession createSession() {
-        try {
-            I2PClient client = I2PClientFactory.createClient();
-            ByteArrayOutputStream baos = new ByteArrayOutputStream(512);
-            Destination dest = client.createDestination(baos);
-            Properties p = getProps();
+    private I2PSession createSession() throws Exception {
+        I2PClient client = I2PClientFactory.createClient();
+        ByteArrayOutputStream baos = new ByteArrayOutputStream(512);
+        Destination dest = client.createDestination(baos);
+        Properties p = getProps();
 
-            I2PSession sess = client.createSession(new ByteArrayInputStream(baos.toByteArray()), p);
-            sess.connect();
-            return sess;
-        } catch (Exception e) {
-            _log.error("error running", e);
-            throw new RuntimeException("b0rk b0rk b0rk");
-        }
+        I2PSession sess = client.createSession(new ByteArrayInputStream(baos.toByteArray()), p);
+        sess.connect();
+        return sess;
     }
     
     private static Properties getProps() {