From 5aaa116c6ae167102c65bcb56cb32d3bf0336fad Mon Sep 17 00:00:00 2001
From: Spencer Gibb <spencer@gibb.us>
Date: Wed, 18 Jan 2017 12:01:00 -0700
Subject: [PATCH] Updates for optional hystrix deps

---
 pom.xml                                                       | 3 +++
 .../cloud/gateway/config/GatewayAutoConfiguration.java        | 4 ++++
 2 files changed, 7 insertions(+)

diff --git a/pom.xml b/pom.xml
index 654a4263..d06083b4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -22,6 +22,7 @@
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 		<java.version>1.8</java.version>
+		<reactor.version>3.0.4.RELEASE</reactor.version>
 	</properties>
 
 	<dependencies>
@@ -69,10 +70,12 @@
 			<artifactId>spring-cloud-starter-hystrix</artifactId>
 			<optional>true</optional>
 		</dependency>
+		<!-- TODO: should be part of spring-cloud-starter-hystrix -->
 		<dependency>
 			<groupId>io.reactivex</groupId>
 			<artifactId>rxjava-reactive-streams</artifactId>
 			<version>1.2.1</version>
+			<optional>true</optional>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
diff --git a/src/main/java/org/springframework/cloud/gateway/config/GatewayAutoConfiguration.java b/src/main/java/org/springframework/cloud/gateway/config/GatewayAutoConfiguration.java
index bd7e3167..d7bbfad2 100644
--- a/src/main/java/org/springframework/cloud/gateway/config/GatewayAutoConfiguration.java
+++ b/src/main/java/org/springframework/cloud/gateway/config/GatewayAutoConfiguration.java
@@ -41,7 +41,10 @@ import org.springframework.cloud.gateway.handler.predicate.UrlRoutePredicate;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import com.netflix.hystrix.HystrixObservableCommand;
+
 import reactor.ipc.netty.http.client.HttpClient;
+import rx.RxReactiveStreams;
 
 /**
  * @author Spencer Gibb
@@ -163,6 +166,7 @@ public class GatewayAutoConfiguration {
 	}
 
 	@Bean(name = "HystrixRouteFilter")
+	@ConditionalOnClass({HystrixObservableCommand.class, RxReactiveStreams.class})
 	public HystrixRouteFilter hystrixRouteFilter() {
 		return new HystrixRouteFilter();
 	}