Add filtering to KV keys methods remove unnecessary optimization (#1175)

nats-io · Jul 8, 2024 · c5a6a26 · c5a6a26
1 parent d695873
commit c5a6a26
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/src/main/java/io/nats/client/impl/NatsFeatureBase.java b/src/main/java/io/nats/client/impl/NatsFeatureBase.java
@@ -79,14 +79,8 @@ protected void visitSubject(List<String> subjects, DeliverPolicy deliverPolicy,
         ConsumerConfiguration.Builder ccb = ConsumerConfiguration.builder()
             .ackPolicy(AckPolicy.None)
             .deliverPolicy(deliverPolicy)
-            .headersOnly(headersOnly);
-
-        if (subjects.size() == 1) {
-            ccb.filterSubject(subjects.get(0));
-        }
-        else {
-            ccb.filterSubjects(subjects);
-        }
+            .headersOnly(headersOnly)
+            .filterSubjects(subjects);
 
         PushSubscribeOptions pso = PushSubscribeOptions.builder()
             .stream(streamName)