Port to Java In-Process SDK 8.0.0.

Author: dario-weswit

pom.xml

@@ -4,7 +4,7 @@
 
   <groupId>com.lightstreamer.examples</groupId>
   <artifactId>rss-adapter-java</artifactId>
-  <version>1.1.0</version>
+  <version>1.2.0</version>
   <packaging>jar</packaging>
 
   <name>Lightstreamer RSS Demo Java Adapter</name>
@@ -65,7 +65,7 @@
     <dependency>
       <groupId>com.lightstreamer</groupId>
       <artifactId>ls-adapter-inprocess</artifactId>
-      <version>7.4.0</version>
+      <version>8.0.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.logging.log4j</groupId>

src/main/java/com/lightstreamer/examples/rss_demo/adapters/RSSMetadataAdapter.java

@@ -20,6 +20,8 @@
 
 import java.io.File;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionStage;
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -98,9 +100,11 @@ private String convertRSSUserName(String item, String session) throws ItemsExcep
      * Triggered by a client "sendMessage" call.
      * The message encodes a chat message from the client.
      */
-    public void notifyUserMessage(String user, String session, String message)
+    public CompletionStage<String> notifyUserMessage(String user, String session, String message)
         throws NotificationException, CreditsException {
 
+        // we won't introduce blocking operations, hence we can proceed inline
+
         if (message == null) {
             logger.warn("Null message received");
             throw new NotificationException("Null message received");
@@ -114,6 +118,8 @@ public void notifyUserMessage(String user, String session, String message)
 
         this.loadRSSFeed();
         this.handleRSSMessage(pieces,message,session);
+
+        return CompletableFuture.completedStage(null);
     }
 
     private void loadRSSFeed() throws CreditsException {