Step 4 – Publishing a message

piotr.kazmierczak · piotr.kazmierczak · commit 098e674db91d · 2016-09-27T19:22:23.000+02:00
diff --git a/src/main/java/io/ably/tutorial/Example.java b/src/main/java/io/ably/tutorial/Example.java
@@ -2,7 +2,9 @@
 
 import io.ably.lib.realtime.AblyRealtime;
 import io.ably.lib.realtime.Channel;
+import io.ably.lib.realtime.CompletionListener;
 import io.ably.lib.types.AblyException;
+import io.ably.lib.types.ErrorInfo;
 import io.ably.lib.types.Message;
 
 public class Example {
@@ -36,5 +38,19 @@ public void onMessage(Message messages) {
                 System.out.println("Message received: " + messages.data);
 			}
         });
+        
+        channel.publish("update", "new message", new CompletionListener() {
+            @Override
+            public void onSuccess() {
+                /* Show success message when message is sent */
+                System.out.println("Message sent");
+            }
+
+            @Override
+            public void onError(ErrorInfo reason) {
+                /* Show error message when something goes wrong */
+            	System.out.println("Message not sent, error occurred: " + reason.message);
+            }
+        });
 	}
 }
