fix: SolaceProducts#266

SchweizerischeBundesbahnen · Apr 23, 2024 · 4a8590e · 4a8590e
1 parent d7056dd
commit 4a8590e
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/src/main/java/com/solace/spring/cloud/stream/binder/provisioning/SolaceQueueProvisioner.java b/src/main/java/com/solace/spring/cloud/stream/binder/provisioning/SolaceQueueProvisioner.java
@@ -175,7 +175,7 @@ private Queue provisionQueue(String name, boolean isDurable, EndpointProperties
 			throw new ProvisioningException(msg, e);
 		}
 
-		if (testFlowCxn) {
+		if (isDurable && testFlowCxn) {
 			try {
 				logger.info(String.format("Testing consumer flow connection to queue %s (will not start it)", name));
 				final ConsumerFlowProperties testFlowProperties = new ConsumerFlowProperties().setEndpoint(queue).setStartState(false);
@@ -184,14 +184,10 @@ private Queue provisionQueue(String name, boolean isDurable, EndpointProperties
 			} catch (JCSMPException e) {
 				String msg = String.format("Failed to connect test consumer flow to queue %s", name);
 
-				if (isDurable && !doDurableProvisioning) {
+				if (!doDurableProvisioning) {
 					msg += ". Provisioning is disabled, queue was not provisioned nor was its configuration validated.";
 				}
-
-				if (e instanceof InvalidOperationException && !isDurable) {
-					msg += ". If the Solace client is not capable of creating temporary queues, consider assigning this consumer to a group?";
-				}
-				logger.warn(msg, e);
+                logger.warn(msg, e);
 				throw new ProvisioningException(msg, e);
 			}
 		} else {