Add test for Connection#getName

nats-io · Feb 7, 2017 · efdfd1d · efdfd1d
1 parent 498372b
commit efdfd1d
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/test/java/io/nats/client/ConnectionImplTest.java b/src/test/java/io/nats/client/ConnectionImplTest.java
@@ -26,11 +26,9 @@
 import static io.nats.client.Nats.defaultOptions;
 import static io.nats.client.UnitTestUtilities.await;
 import static io.nats.client.UnitTestUtilities.defaultInfo;
-import static io.nats.client.UnitTestUtilities.newDefaultConnection;
 import static io.nats.client.UnitTestUtilities.newMockedConnection;
 import static io.nats.client.UnitTestUtilities.newMockedTcpConnection;
 import static io.nats.client.UnitTestUtilities.newMockedTcpConnectionFactory;
-import static io.nats.client.UnitTestUtilities.runDefaultServer;
 import static io.nats.client.UnitTestUtilities.setLogLevel;
 import static org.junit.Assert.assertArrayEquals;
 import static org.junit.Assert.assertEquals;
@@ -890,6 +888,16 @@ public void testGetConnectedServerInfo() throws Exception {
         }
     }
 
+    @Test
+    public void testGetName() throws Exception {
+        final String name = "foobar";
+        Options opts = new Options.Builder().name(name).build();
+        try (Connection nc = newMockedConnection(opts)) {
+            assertTrue(!nc.isClosed());
+            assertEquals(name, nc.getName());
+        }
+    }
+
     @Test
     public void testPublishClosedConnection() throws Exception {
         thrown.expect(IllegalStateException.class);