File tree Expand file tree Collapse file tree
branches/autosynth-pubsub Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -116,7 +116,7 @@ refs/heads/autosynth-compute: 8e86445e504cea6f99b9fb237bfd7f0e5ef8b3ce
116116refs/heads/autosynth-container: f6384095f50b31bfc8208542a49181e158d3681c
117117refs/heads/autosynth-dataproc: bc74a8841bc1693d7945d991d15979df550b1fd1
118118refs/heads/autosynth-monitoring: e67db7395a868e5f6ecc3476eb4a91c47abd4234
119- refs/heads/autosynth-pubsub: f27d35d5f51ccaf06f12084dbc75f332626ffe56
119+ refs/heads/autosynth-pubsub: a29a7cf422a2263b796bc21b2304701d322f0217
120120refs/heads/autosynth-video-intelligence: 3e8faeeee2f803271529bd6e89b621c1ca098628
121121refs/heads/autosynth-vision: d758c43ba2ef4f4f7ad07b722617cb39fe3f29db
122122refs/heads/spanner: 54a5e197bfe0a004e13c190427f46c3413ab572d
Original file line number Diff line number Diff line change @@ -156,50 +156,7 @@ uses the `RemoteLoggingHelper` to create a metric.
156156
157157You can test against a Pub/Sub emulator:
158158
159- 1 . [ Install Cloud SDK] ( https://cloud.google.com/sdk/downloads )
160-
161- 2 . Start the emulator:
162- ``` shell
163- $ gcloud beta emulators pubsub start
164- ```
165-
166- To determine which host/port the emulator is running on:
167- ``` shell
168- $ gcloud beta emulators pubsub env-init
169- # Sample output:
170- # export PUBSUB_EMULATOR_HOST=localhost:8759
171- ```
172-
173- 3 . Point your client to the emulator.
174- ``` java
175- String hostport = System . getenv(" PUBSUB_EMULATOR_HOST" );
176- ManagedChannel channel = ManagedChannelBuilder . forTarget(hostport). usePlaintext(true ). build();
177- try {
178- ChannelProvider channelProvider = FixedChannelProvider . create(channel);
179- CredentialsProvider credentialsProvider = new NoCredentialsProvider ();
180-
181- // Similarly for SubscriptionAdminSettings
182- TopicAdminClient topicClient = TopicAdminClient . create(
183- TopicAdminSettings
184- .defaultBuilder()
185- .setTransportProvider(
186- GrpcTransportProvider . newBuilder()
187- .setChannelProvider(channelProvider)
188- .build())
189- .setCredentialsProvider(credentialsProvider)
190- .build());
191-
192- // Similarly for Subscriber
193- Publisher publisher =
194- Publisher
195- .defaultBuilder(topicName)
196- .setChannelProvider(channelProvider)
197- .setCredentialsProvider(credentialsProvider)
198- .build();
199- } finally {
200- channel. shutdown();
201- }
202- ```
159+ 1 . [ Set up the emulator] ( https://cloud.google.com/pubsub/docs/emulator )
203160
204161### Testing code that uses Redis
205162
You can’t perform that action at this time.
0 commit comments