From 2667b7be685f13de493daff8f7886ae7dcb27a37 Mon Sep 17 00:00:00 2001
From: Marius Bogoevici <mbogoevici@pivotal.io>
Date: Fri, 16 Dec 2016 09:36:40 -0500
Subject: [PATCH] Make Reactive autoconfiguration conditional on BindingService

---
 .../stream/reactive/ReactiveSupportAutoConfiguration.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/spring-cloud-stream-reactive/src/main/java/org/springframework/cloud/stream/reactive/ReactiveSupportAutoConfiguration.java b/spring-cloud-stream-reactive/src/main/java/org/springframework/cloud/stream/reactive/ReactiveSupportAutoConfiguration.java
index 4dc317058..f71deacb4 100644
--- a/spring-cloud-stream-reactive/src/main/java/org/springframework/cloud/stream/reactive/ReactiveSupportAutoConfiguration.java
+++ b/spring-cloud-stream-reactive/src/main/java/org/springframework/cloud/stream/reactive/ReactiveSupportAutoConfiguration.java
@@ -22,7 +22,9 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import reactor.core.scheduler.Schedulers;
 
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.cloud.stream.binding.BindingService;
 import org.springframework.cloud.stream.converter.CompositeMessageConverterFactory;
 import org.springframework.cloud.stream.reactive.reactor.core.scheduler.NoInterruptOnCancelSchedulerFactory;
 import org.springframework.context.annotation.Bean;
@@ -33,6 +35,7 @@ import org.springframework.util.ClassUtils;
  * @author Marius Bogoevici
  */
 @Configuration
+@ConditionalOnBean(BindingService.class)
 public class ReactiveSupportAutoConfiguration {
 
 	private static Log log = LogFactory.getLog(ReactiveSupportAutoConfiguration.class);