File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
5757refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
5858refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
5959refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
60- refs/heads/tswast-patch-1: 59d1c1f8b29a34a515f057748fe097157681aab8
60+ refs/heads/tswast-patch-1: ff2b1b62822b747cd2f943f3f9fed0a264acea45
6161refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b
Original file line number Diff line number Diff line change @@ -147,17 +147,30 @@ $ gcloud beta emulators pubsub env-init
147147
1481483. Point your client to the emulator.
149149```java
150- ChannelProvider channelProvider =
151- // SubscriptionAdminSettings works too.
152- TopicAdminSettings.defaultChannelProviderBuilder()
153- .setEndpoint(System.getenv("PUBSUB_EMULATOR_HOST"))
154- .setCredentialsProvider(
155- FixedCredentialsProvider.create(NoCredentials.getInstance()))
156- .build();
157- TopicAdminClient topicClient = TopicAdminClient.create(
158- TopicAdminSettings.defaultBuilder().setChannelProvider(channelProvider).build());
159- Publisher publisher =
160- Publisher.newBuilder(topicName).setChannelProvider(channelProvider).build();
150+ String hostport = System.getenv("PUBSUB_EMULATOR_HOST");
151+ ManagedChannel channel = ManagedChannelBuilder.forTarget(hostport).usePlaintext(true).build();
152+ try {
153+ ChannelProvider channelProvider = FixedChannelProvider.create(channel);
154+ CredentialsProvider credentialsProvider = new NoCredentialsProvider();
155+
156+ // Similarly for SubscriptionAdminSettings
157+ TopicAdminClient topicClient = TopicAdminClient.create(
158+ TopicAdminSettings
159+ .defaultBuilder()
160+ .setChannelProvider(channelProvider)
161+ .setCredentialsProvider(credentialsProvider)
162+ .build());
163+
164+ // Similarly for Subscriber
165+ Publisher publisher =
166+ Publisher
167+ .newBuilder(topicName)
168+ .setChannelProvider(channelProvider)
169+ .setCredentialsProvider(credentialsProvider)
170+ .build();
171+ } finally {
172+ channel.shutdown();
173+ }
161174```
162175
163176### Testing code that uses Resource Manager
You can’t perform that action at this time.
0 commit comments