Skip to content

Commit 7277914

Browse files
authored
---
yaml --- r: 8177 b: refs/heads/tswast-patch-1 c: ff2b1b6 h: refs/heads/master i: 8175: 2160085
1 parent f4a74b6 commit 7277914

2 files changed

Lines changed: 25 additions & 12 deletions

File tree

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
5757
refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
5858
refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
5959
refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
60-
refs/heads/tswast-patch-1: 59d1c1f8b29a34a515f057748fe097157681aab8
60+
refs/heads/tswast-patch-1: ff2b1b62822b747cd2f943f3f9fed0a264acea45
6161
refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b

branches/tswast-patch-1/TESTING.md

Lines changed: 24 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -147,17 +147,30 @@ $ gcloud beta emulators pubsub env-init
147147

148148
3. 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

0 commit comments

Comments
 (0)