Update to use EventStreamClientFactory. Removed ExactlyOnceMultithrea…

…dedProcessor.

Signed-off-by: Claudio Fahey <[email protected]>

pravega-client-examples/src/main/java/io/pravega/example/streamprocessing/EventDebugSink.java

@@ -10,10 +10,17 @@
  */
 package io.pravega.example.streamprocessing;
 
-import io.pravega.client.ClientFactory;
+import io.pravega.client.ClientConfig;
+import io.pravega.client.EventStreamClientFactory;
 import io.pravega.client.admin.ReaderGroupManager;
 import io.pravega.client.admin.StreamManager;
-import io.pravega.client.stream.*;
+import io.pravega.client.stream.EventRead;
+import io.pravega.client.stream.EventStreamReader;
+import io.pravega.client.stream.ReaderConfig;
+import io.pravega.client.stream.ReaderGroupConfig;
+import io.pravega.client.stream.ScalingPolicy;
+import io.pravega.client.stream.Stream;
+import io.pravega.client.stream.StreamConfiguration;
 import io.pravega.client.stream.impl.UTF8StringSerializer;
 import org.slf4j.LoggerFactory;
 
@@ -49,6 +56,7 @@ public static void main(String[] args) throws Exception {
     }
 
     public void run() throws Exception {
+        final ClientConfig clientConfig = ClientConfig.builder().controllerURI(controllerURI).build();
         try (StreamManager streamManager = StreamManager.create(controllerURI)) {
             streamManager.createScope(scope);
             StreamConfiguration streamConfig = StreamConfiguration.builder()
@@ -69,7 +77,7 @@ public void run() throws Exception {
             readerGroupManager.createReaderGroup(readerGroup, readerGroupConfig);
         }
 
-        try (ClientFactory clientFactory = ClientFactory.withScope(scope, controllerURI);
+        try (EventStreamClientFactory clientFactory = EventStreamClientFactory.withScope(scope, clientConfig);
              EventStreamReader<String> reader = clientFactory.createReader(
                      "reader",
                      readerGroup,

pravega-client-examples/src/main/java/io/pravega/example/streamprocessing/EventGenerator.java

@@ -10,7 +10,8 @@
  */
 package io.pravega.example.streamprocessing;
 
-import io.pravega.client.ClientFactory;
+import io.pravega.client.ClientConfig;
+import io.pravega.client.EventStreamClientFactory;
 import io.pravega.client.admin.StreamManager;
 import io.pravega.client.stream.EventStreamWriter;
 import io.pravega.client.stream.EventWriterConfig;
@@ -52,6 +53,7 @@ public static void main(String[] args) throws Exception {
     }
 
     public void run() throws Exception {
+        final ClientConfig clientConfig = ClientConfig.builder().controllerURI(controllerURI).build();
         try (StreamManager streamManager = StreamManager.create(controllerURI)) {
             streamManager.createScope(scope);
             StreamConfiguration streamConfig = StreamConfiguration.builder()
@@ -64,8 +66,7 @@ public void run() throws Exception {
         }
 
         Random rand = new Random(42);
-
-        try (ClientFactory clientFactory = ClientFactory.withScope(scope, controllerURI);
+        try (EventStreamClientFactory clientFactory = EventStreamClientFactory.withScope(scope, clientConfig);
              EventStreamWriter<String> writer = clientFactory.createEventWriter(
                      outputStreamName,
                      new UTF8StringSerializer(),
@@ -90,7 +91,7 @@ public void run() throws Exception {
                         String.format("%06d", eventCounter),
                         String.format("%08d", sum),
                         message);
-                final CompletableFuture writeFuture = writer.writeEvent(routingKey, message);
+                final CompletableFuture<Void> writeFuture = writer.writeEvent(routingKey, message);
                 Thread.sleep(1000);
             }
         }