From fde2c9e51a677c9c6cd7c9ace6488a0220d43909 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Wed, 7 Dec 2022 16:00:10 -0800
Subject: [PATCH] Make integration (test) binder default when multiple binders
 are available

---
 .../cloud/stream/binder/DefaultBinderFactory.java           | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java
index 40ca234b4..09307efb1 100644
--- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java
+++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java
@@ -191,7 +191,11 @@ public class DefaultBinderFactory implements BinderFactory, DisposableBean, Appl
 				Set<String> defaultCandidateConfigurations = new HashSet<>();
 				for (Map.Entry<String, BinderConfiguration> binderConfigurationEntry : this.binderConfigurations
 						.entrySet()) {
-					if (binderConfigurationEntry.getValue().isDefaultCandidate()) {
+					if ("integration".equals(binderConfigurationEntry.getKey())) {
+						defaultCandidateConfigurations.add(binderConfigurationEntry.getKey());
+						break;
+					}
+					else if (binderConfigurationEntry.getValue().isDefaultCandidate()) {
 						defaultCandidateConfigurations
 								.add(binderConfigurationEntry.getKey());
 					}