From f6f2bf3b070efc010bae8fd148339c964b795f57 Mon Sep 17 00:00:00 2001 From: Tamimi Ahmad Date: Tue, 30 Apr 2024 06:18:30 -0700 Subject: [PATCH] rename consumer to receiver to match API (#36) --- build.gradle | 4 ++-- src/main/java/com/solace/samples/java/HelloWorld.java | 2 +- .../patterns/{DirectSubscriber.java => DirectReceiver.java} | 4 ++-- .../{GuaranteedSubscriber.java => GuaranteedReceiver.java} | 6 +++--- 4 files changed, 8 insertions(+), 8 deletions(-) rename src/main/java/com/solace/samples/java/patterns/{DirectSubscriber.java => DirectReceiver.java} (98%) rename src/main/java/com/solace/samples/java/patterns/{GuaranteedSubscriber.java => GuaranteedReceiver.java} (97%) diff --git a/build.gradle b/build.gradle index 558cd0c..953cfa2 100644 --- a/build.gradle +++ b/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', diff --git a/src/main/java/com/solace/samples/java/HelloWorld.java b/src/main/java/com/solace/samples/java/HelloWorld.java index b580403..d57bb26 100644 --- a/src/main/java/com/solace/samples/java/HelloWorld.java +++ b/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) -> { diff --git a/src/main/java/com/solace/samples/java/patterns/DirectSubscriber.java b/src/main/java/com/solace/samples/java/patterns/DirectReceiver.java similarity index 98% rename from src/main/java/com/solace/samples/java/patterns/DirectSubscriber.java rename to src/main/java/com/solace/samples/java/patterns/DirectReceiver.java index 6ef15e7..585c55f 100644 --- a/src/main/java/com/solace/samples/java/patterns/DirectSubscriber.java +++ b/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"; diff --git a/src/main/java/com/solace/samples/java/patterns/GuaranteedSubscriber.java b/src/main/java/com/solace/samples/java/patterns/GuaranteedReceiver.java similarity index 97% rename from src/main/java/com/solace/samples/java/patterns/GuaranteedSubscriber.java rename to src/main/java/com/solace/samples/java/patterns/GuaranteedReceiver.java index 88328f6..c678033 100644 --- a/src/main/java/com/solace/samples/java/patterns/GuaranteedSubscriber.java +++ b/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 q_java_sub has already been * created for it, and the topic subscription solace/samples/*/pers/> * 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";