ADAP-207: fixed tests

wenjunche · wenjunche · commit 39918ed324b3 · 2022-02-20T12:01:41.000-05:00
diff --git a/src/main/java/com/openfin/desktop/demo/ChannelExample.java b/src/main/java/com/openfin/desktop/demo/ChannelExample.java
@@ -119,6 +119,15 @@ public void createChannelClient() {
         JSONObject payload = new JSONObject();
         payload.put("name", "java example");
         desktopConnection.getChannel(CHANNEL_NAME).connectAsync(false, payload).thenAccept(client -> {
+            client.addChannelListener(new ChannelListener() {
+                @Override
+                public void onChannelConnect(ConnectionEvent connectionEvent) {
+                }
+                @Override
+                public void onChannelDisconnect(ConnectionEvent connectionEvent) {
+                    logger.info("channel disconnected {}", connectionEvent.getChannelId());
+                }
+            });
             client.register("event", new ChannelAction() {
                 @Override
                 public JSONObject invoke(String action, Object payload, JSONObject senderIdentity) {
diff --git a/src/test/java/com/openfin/desktop/ChannelTest.java b/src/test/java/com/openfin/desktop/ChannelTest.java
@@ -16,12 +16,7 @@
 import org.slf4j.LoggerFactory;
 
 /**
- * JUnit tests for com.openfin.desktop.InterApplicationBus class
- *
- * Test cases in this class need to have access to an OpenFin HTML5 app to
- * verify sub/pub workflow. Sources for the app can be found in release
- * directory: PubSubExample.html. It is hosted by OpenFin at
- * https://cdn.openfin.co/examples/junit/PubSubExample.html
+ * JUnit tests for OpenFin Channel API
  *
  * Created by wche on 1/27/16.
  *
@@ -321,16 +316,15 @@ public void onClientDisconnect(ChannelClientConnectEvent connectionEvent) {
 			});
 
 			desktopConnection.getChannel(channelName).connectAsync().thenAccept(client -> {
-				client.addChannelListener(new ChannelListener() {
+				client.disconnect(new AckListener() {
 					@Override
-					public void onChannelConnect(ConnectionEvent connectionEvent) {
+					public void onSuccess(Ack ack) {
+						latch.countDown();
 					}
 					@Override
-					public void onChannelDisconnect(ConnectionEvent connectionEvent) {
-						latch.countDown();
+					public void onError(Ack ack) {
 					}
 				});
-				client.disconnect(null);
 			});
 		});
 		latch.await(10, TimeUnit.SECONDS);
