Divyam2001
diff --git a/‎RELEASENOTES-ADAPTER.md‎
Lines changed: 4 additions & 0 deletions b/‎RELEASENOTES-ADAPTER.md‎
Lines changed: 4 additions & 0 deletions
diff --git a/‎pom.xml‎
Lines changed: 1 addition & 1 deletion b/‎pom.xml‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/main/java/com/openfin/desktop/demo/ChannelExample.java‎
Lines changed: 17 additions & 5 deletions b/‎src/main/java/com/openfin/desktop/demo/ChannelExample.java‎
Lines changed: 17 additions & 5 deletions
@@ -1,3 +1,7 @@
+# Version 7.2.1
+## New Features
+* Add support for FDC3 service
+
 # Version 7.1.3
 ## New Features
 * Add support for the new notification service
 
@@ -58,7 +58,7 @@
         <dependency>
             <groupId>co.openfin</groupId>
             <artifactId>openfin-desktop-java-adapter</artifactId>
-            <version>7.1.3-SNAPSHOT</version>
+            <version>7.2.1-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>co.openfin</groupId>
 
@@ -47,7 +47,7 @@ public ChannelExample() {
      * Create a provider that supports "getValue", "increment" and "incrementBy n" actions
      */
     public void createChannelProvider() {
-        desktopConnection.getChannel().addChannelListener(new ChannelListener() {
+        desktopConnection.getChannel(CHANNEL_NAME).addChannelListener(new ChannelListener() {
             @Override
             public void onChannelConnect(ConnectionEvent connectionEvent) {
                 logger.info(String.format("provider receives channel connect event from %s ", connectionEvent.getUuid()));
@@ -57,7 +57,7 @@ public void onChannelDisconnect(ConnectionEvent connectionEvent) {
                 logger.info(String.format("provider receives channel disconnect event from %s ", connectionEvent.getUuid()));
             }
         });
-        desktopConnection.getChannel().create(CHANNEL_NAME, new AsyncCallback<ChannelProvider>() {
+        desktopConnection.getChannel(CHANNEL_NAME).create(new AsyncCallback<ChannelProvider>() {
             @Override
             public void onSuccess(ChannelProvider provider) {
                 //provider created, register actions.
@@ -78,6 +78,7 @@ public JSONObject invoke(String action, JSONObject payload) {
                         logger.info(String.format("provider processing action %s, payload=%s", action, payload.toString()));
                         JSONObject obj = new JSONObject();
                         obj.put("value", x.incrementAndGet());
+                        provider.publish("event", obj, null);
                         return obj;
                     }
                 });
@@ -99,9 +100,18 @@ public JSONObject invoke(String action, JSONObject payload) {
      * Create a channel client that invokes "getValue", "increment" and "incrementBy n" actions
      */
     public void createChannelClient() {
-        desktopConnection.getChannel().connect(CHANNEL_NAME, new AsyncCallback<ChannelClient>() {
+        desktopConnection.getChannel(CHANNEL_NAME).connect(CHANNEL_NAME + "Client", new AsyncCallback<ChannelClient>() {
             @Override
             public void onSuccess(ChannelClient client) {
+                // register a channel event
+                client.register("event", new ChannelAction() {
+                    @Override
+                    public JSONObject invoke(String action, JSONObject payload) {
+                        logger.info("channel event {}", action);
+                        return null;
+                    }
+                });
+
                 //connected to provider, invoke actions provided by the provider.
                 //get current value
                 client.dispatch("getValue", null, new AckListener() {
@@ -148,7 +158,6 @@ public void onError(Ack ack) {
                     }
                 });
             }
-
         });
     }
 
@@ -164,12 +173,13 @@ public void onReady() {
 
     @Override
     public void onClose(String error) {
+        logger.info("onClose, value={}", error);
         latch.countDown();
     }
 
     @Override
     public void onError(String reason) {
-
+        logger.info("onError, value={}", reason);
     }
 
     @Override
@@ -194,5 +204,7 @@ public static void main(String[] args) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
+
+        java.lang.System.exit(0);
     }
 }