Add redirect scheme (#204)

apache · Oct 31, 2019 · ee8afba · ee8afba
1 parent 83c59fb
commit ee8afba
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/main/java/io/streamnative/pulsar/manager/zuul/LocationHeaderRewritingFilter.java b/src/main/java/io/streamnative/pulsar/manager/zuul/LocationHeaderRewritingFilter.java
@@ -48,6 +48,8 @@ public class LocationHeaderRewritingFilter extends ZuulFilter {
     @Value("${redirect.port}")
     private String port;
 
+    @Value("${redirect.scheme}")
+    private String scheme;
     @Override
     public String filterType() {
         return POST_TYPE;
@@ -86,7 +88,7 @@ public Object run() {
                 UriComponents redirectedUriComps = redirectedUriBuilder.build();
 
                 String modifiedLocation = redirectedUriBuilder
-                        .scheme(originalRequestUri.getScheme())
+                        .scheme(scheme)
                         .host(host)
                         .port(port).replacePath(redirectedUriComps.getPath())
                         .queryParam("redirect", true)

diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -83,6 +83,7 @@ pulsar-manager.password=pulsar
 bookie.host=http://localhost:8050
 bookie.enable=false
 
+redirect.scheme=http
 redirect.host=localhost
 redirect.port=9527