Test reconnect with a local connector.

cojen · Oct 7, 2024 · 73a1632 · 73a1632
1 parent f11460d
commit 73a1632
Showing 1 changed file with 24 additions and 0 deletions.
diff --git a/src/test/java/org/cojen/dirmi/RestorableTest.java b/src/test/java/org/cojen/dirmi/RestorableTest.java
@@ -67,6 +67,16 @@ public void setup() throws Exception {
         mSession = mEnv.connect(R1.class, "main", "localhost", mServerSocket.getLocalPort());
     }
 
+    private void setupLocal() throws Exception {
+        mEnv = Environment.create();
+        mEnv.connector(Connector.local(mEnv));
+        mEnv.export("main", new R1Server());
+        mEnv.reconnectDelayMillis(100);
+        mEnv.pingTimeoutMillis(1000);
+
+        mSession = mEnv.connect(R1.class, "main", null);
+    }
+
     @After
     public void teardown() throws Exception {
         if (mAcceptor != null) {
@@ -169,6 +179,20 @@ public boolean test(Session<?> session, Throwable ex) {
 
     @Test
     public void explicitReconnect() throws Exception {
+        explicitReconnect(false);
+    }
+
+    @Test
+    public void explicitReconnectLocal() throws Exception {
+        explicitReconnect(true);
+    }
+
+    private void explicitReconnect(boolean local) throws Exception {
+        if (local) {
+            teardown();
+            setupLocal();
+        }
+
         assertEquals(Session.State.CONNECTED, mSession.state());
 
         R1 root = mSession.root();