fix tests

SolaceDev · Aug 9, 2024 · e962828 · e962828
1 parent c416f4b
commit e962828
Showing 1 changed file with 3 additions and 9 deletions.
diff --git a/...nder/src/test/java/com/solace/spring/cloud/stream/binder/SolaceBinderSubscriptionsIT.java b/...nder/src/test/java/com/solace/spring/cloud/stream/binder/SolaceBinderSubscriptionsIT.java
@@ -29,7 +29,6 @@
 import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
 
 import java.util.Arrays;
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
@@ -170,9 +169,7 @@ private static void assertActualSubscriptionsAreCorrect(SpringCloudStreamContext
                                                             boolean addDestinationAsSubscriptionToQueue)
             throws ApiException {
         String msgVpnName = (String) context.getJcsmpSession().getProperty(JCSMPProperties.VPN_NAME);
-        Set<String> expectedSubscriptions = getExpectedQueueSubscriptions(
-                sempV2Api.monitor().getMsgVpnQueue(msgVpnName, queueName, null).getData().isDurable(),
-                addDestinationAsSubscriptionToQueue);
+        Set<String> expectedSubscriptions = getExpectedQueueSubscriptions(addDestinationAsSubscriptionToQueue);
         List<MonitorMsgVpnQueueSubscription> actualSubscriptions =
                 sempV2Api.monitor().getMsgVpnQueueSubscriptions(msgVpnName, queueName, null, null, null, null).getData();
 
@@ -183,17 +180,14 @@ private static void assertActualSubscriptionsAreCorrect(SpringCloudStreamContext
         assertEquals(expectedSubscriptions.size(), actualSubscriptions.size(), "Some subscriptions are missing");
     }
 
-    private static Set<String> getExpectedQueueSubscriptions(boolean isDurableQueue,
-                                                             boolean addDestinationAsSubscriptionToQueue) {
+    private static Set<String> getExpectedQueueSubscriptions(boolean addDestinationAsSubscriptionToQueue) {
         if (addDestinationAsSubscriptionToQueue) {
             Set<String> expectedSubscriptions = new HashSet<>();
             expectedSubscriptions.add(DESTINATION);
             expectedSubscriptions.addAll(Arrays.asList(ADDITIONAL_SUBSCRIPTIONS));
             return expectedSubscriptions;
-        } else if (!isDurableQueue) {
-            return new HashSet<>(Arrays.asList(ADDITIONAL_SUBSCRIPTIONS));
         } else {
-            return Collections.emptySet();
+            return new HashSet<>(Arrays.asList(ADDITIONAL_SUBSCRIPTIONS));
         }
     }
 }