rename consumer to receiver to match API (#36)

Author: TamimiGitHub

build.gradle

@@ -76,11 +76,11 @@ tasks.withType(JavaCompile).all {
 def scripts = [
         'HelloWorld'                    : 'com.solace.samples.java.HelloWorld',
         'DirectPublisher'               : 'com.solace.samples.java.patterns.DirectPublisher',
-        'DirectSubscriber'              : 'com.solace.samples.java.patterns.DirectSubscriber',
+        'DirectReceiver'              : 'com.solace.samples.java.patterns.DirectReceiver',
         'DirectProcessor'               : 'com.solace.samples.java.patterns.DirectProcessor',
         'GuaranteedNonBlockingPublisher': 'com.solace.samples.java.patterns.GuaranteedNonBlockingPublisher',
         'GuaranteedBlockingPublisher'   : 'com.solace.samples.java.patterns.GuaranteedBlockingPublisher',
-        'GuaranteedSubscriber'          : 'com.solace.samples.java.patterns.GuaranteedSubscriber',
+        'GuaranteedReceiver'          : 'com.solace.samples.java.patterns.GuaranteedReceiver',
         'GuaranteedProcessor'           : 'com.solace.samples.java.patterns.GuaranteedProcessor',
         'DirectReplierBlocking'         : 'com.solace.samples.java.patterns.DirectReplierBlocking',
         'DirectRequestorBlocking'       : 'com.solace.samples.java.patterns.DirectRequestorBlocking',

src/main/java/com/solace/samples/java/HelloWorld.java

@@ -76,7 +76,7 @@ public static void main(String... args) throws IOException {
         final DirectMessagePublisher publisher = messagingService.createDirectMessagePublisherBuilder()
                 .onBackPressureWait(1).build().start();
 
-        // create and start the subscriber
+        // create and start the receiver
         final DirectMessageReceiver receiver = messagingService.createDirectMessageReceiverBuilder()
                 .withSubscriptions(TopicSubscription.of(TOPIC_PREFIX + "*/hello/>")).build().start();
         final MessageHandler messageHandler = (inboundMessage) -> {

…ples/java/patterns/DirectSubscriber.java …amples/java/patterns/DirectReceiver.javasrc/main/java/com/solace/samples/java/patterns/DirectSubscriber.java renamed to src/main/java/com/solace/samples/java/patterns/DirectReceiver.java src/main/java/com/solace/samples/java/patterns/DirectSubscriber.java renamed to src/main/java/com/solace/samples/java/patterns/DirectReceiver.java

@@ -31,9 +31,9 @@
 /**
  * A more performant sample that shows an application that subscribes.
  */
-public class DirectSubscriber {
+public class DirectReceiver {
 
-    private static final String SAMPLE_NAME = DirectSubscriber.class.getSimpleName();
+    private static final String SAMPLE_NAME = DirectReceiver.class.getSimpleName();
     private static final String TOPIC_PREFIX = "solace/samples/";  // used as the topic "root"
     private static final String API = "Java";
 

…/java/patterns/GuaranteedSubscriber.java …es/java/patterns/GuaranteedReceiver.javasrc/main/java/com/solace/samples/java/patterns/GuaranteedSubscriber.java renamed to src/main/java/com/solace/samples/java/patterns/GuaranteedReceiver.java src/main/java/com/solace/samples/java/patterns/GuaranteedSubscriber.java renamed to src/main/java/com/solace/samples/java/patterns/GuaranteedReceiver.java

@@ -31,14 +31,14 @@
 import com.solace.messaging.resources.Queue;
 
 /**
- * A sample application showing non-blocking subscriber for Guaranteed messages.
+ * A sample application showing non-blocking Receiver for Guaranteed messages.
  * This application assumes a queue named <code>q_java_sub</code> has already been
  * created for it, and the topic subscription <code>solace/samples/&ast;/pers/></code>
  * has been added to it. 
  */
-public class GuaranteedSubscriber {
+public class GuaranteedReceiver {
 
-    private static final String SAMPLE_NAME = GuaranteedSubscriber.class.getSimpleName();
+    private static final String SAMPLE_NAME = GuaranteedReceiver.class.getSimpleName();
     private static final String QUEUE_NAME = "q_java_sub";
     private static final String API = "Java";