|
30 | 30 | import io.grpc.ManagedChannelRegistryAccessor; |
31 | 31 | import io.grpc.NameResolverRegistry; |
32 | 32 | import io.grpc.TlsChannelCredentials; |
| 33 | +import io.grpc.internal.testing.FakeNameResolverProvider; |
33 | 34 | import io.grpc.stub.StreamObserver; |
34 | 35 | import io.grpc.testing.GrpcCleanupRule; |
35 | 36 | import io.grpc.testing.protobuf.SimpleRequest; |
@@ -124,9 +125,14 @@ public void managedChannelRegistry_newChannelBuilder() { |
124 | 125 | @Test |
125 | 126 | public void managedChannelRegistry_newChannelBuilderForNameResolverRegistry() { |
126 | 127 | Assume.assumeTrue(Utils.isEpollAvailable()); |
| 128 | + NameResolverRegistry nameResolverRegistry = new NameResolverRegistry(); |
| 129 | + DomainSocketAddress socketAddress = new DomainSocketAddress("test-server"); |
| 130 | + FakeNameResolverProvider fakeNameResolverProvider = new FakeNameResolverProvider( |
| 131 | + "unix:///sock.sock", socketAddress); |
| 132 | + nameResolverRegistry.register(fakeNameResolverProvider); |
127 | 133 | ManagedChannelBuilder<?> managedChannelBuilder |
128 | | - = Grpc.newChannelBuilderForNameResolverRegistry("unix:///sock.sock", |
129 | | - InsecureChannelCredentials.create(), NameResolverRegistry.getDefaultRegistry()); |
| 134 | + = Grpc.newChannelBuilder("unix:///sock.sock", |
| 135 | + InsecureChannelCredentials.create(), nameResolverRegistry); |
130 | 136 | assertThat(managedChannelBuilder).isNotNull(); |
131 | 137 | ManagedChannel channel = managedChannelBuilder.build(); |
132 | 138 | assertThat(channel).isNotNull(); |
|
0 commit comments