SpringCloud/spring-cloud-gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Handles DataBufferWrapper

Browse Source
This commit is contained in:
Spencer Gibb
2020-01-24 17:35:27 -05:00
parent bc3841ce1b
commit 7459be61bd
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/NettyRoutingFilter.java
View File

@@ -40,6 +40,7 @@ import org.springframework.cloud.gateway.route.Route;
import org.springframework.cloud.gateway.support.TimeoutException;
import org.springframework.core.Ordered;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferWrapper;
import org.springframework.core.io.buffer.DefaultDataBuffer;
import org.springframework.core.io.buffer.NettyDataBuffer;
import org.springframework.http.HttpHeaders;
@@ -215,6 +216,10 @@ public class NettyRoutingFilter implements GlobalFilter, Ordered {
DefaultDataBuffer buffer = (DefaultDataBuffer) dataBuffer;
return Unpooled.wrappedBuffer(buffer.getNativeBuffer());
}
else if (dataBuffer instanceof DataBufferWrapper) {
DataBufferWrapper wrapper = (DataBufferWrapper) dataBuffer;
return Unpooled.wrappedBuffer(wrapper.asByteBuffer());
}
throw new IllegalArgumentException(
"Unable to handle DataBuffer of type " + dataBuffer.getClass());
}