grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

servlet: Don't assume ManagedChannelBuilder will be NettyChannelBuilder (#9914)

This commit is contained in:
Stanley Cheung 2023-02-24 13:44:32 -08:00 committed by GitHub
parent 26c2db9c39
commit 111033e818
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
servlet/src/jettyTest/java/io/grpc/servlet/JettyInteropTest.java
View File

@ -83,10 +83,9 @@ public class JettyInteropTest extends AbstractInteropTest {
@Override @Override
protected ManagedChannelBuilder<?> createChannelBuilder() { protected ManagedChannelBuilder<?> createChannelBuilder() {
NettyChannelBuilder builder = NettyChannelBuilder builder = NettyChannelBuilder.forAddress(HOST, port)
(NettyChannelBuilder) ManagedChannelBuilder.forAddress(HOST, port) .usePlaintext()
.usePlaintext() .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE);
.maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE);
InternalNettyChannelBuilder.setStatsEnabled(builder, false); InternalNettyChannelBuilder.setStatsEnabled(builder, false);
builder.intercept(createCensusStatsClientInterceptor()); builder.intercept(createCensusStatsClientInterceptor());
return builder; return builder;

7
servlet/src/tomcatTest/java/io/grpc/servlet/TomcatInteropTest.java
View File

@ -94,10 +94,9 @@ public class TomcatInteropTest extends AbstractInteropTest {
@Override @Override
protected ManagedChannelBuilder<?> createChannelBuilder() { protected ManagedChannelBuilder<?> createChannelBuilder() {
NettyChannelBuilder builder = NettyChannelBuilder builder = NettyChannelBuilder.forAddress(HOST, port)
(NettyChannelBuilder) ManagedChannelBuilder.forAddress(HOST, port) .usePlaintext()
.usePlaintext() .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE);
.maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE);
InternalNettyChannelBuilder.setStatsEnabled(builder, false); InternalNettyChannelBuilder.setStatsEnabled(builder, false);
builder.intercept(createCensusStatsClientInterceptor()); builder.intercept(createCensusStatsClientInterceptor());
return builder; return builder;

2
servlet/src/undertowTest/java/io/grpc/servlet/UndertowInteropTest.java
View File

@ -111,7 +111,7 @@ public class UndertowInteropTest extends AbstractInteropTest {
@Override @Override
protected ManagedChannelBuilder<?> createChannelBuilder() { protected ManagedChannelBuilder<?> createChannelBuilder() {
NettyChannelBuilder builder = (NettyChannelBuilder) ManagedChannelBuilder NettyChannelBuilder builder = NettyChannelBuilder
.forAddress(HOST, port) .forAddress(HOST, port)
.usePlaintext() .usePlaintext()
.maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE); .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE);