This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new ffc8232 Add a more complete FnHarness#main method
ffc8232 is described below
commit ffc823209f98577605822a273aa2a559780a7ba8
Author: Thomas Groh <[email protected]>
AuthorDate: Thu Jan 11 16:07:38 2018 -0800
Add a more complete FnHarness#main method
This can be used within tests to configure the channel factory and
stream observer factory used by the harness.
---
.../main/java/org/apache/beam/fn/harness/FnHarness.java | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git
a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
index 7c0590d..7c2ffe7 100644
--- a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
+++ b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
@@ -104,6 +104,20 @@ public class FnHarness {
}
StreamObserverFactory streamObserverFactory =
HarnessStreamObserverFactories.fromOptions(options);
+ main(
+ options,
+ loggingApiServiceDescriptor,
+ controlApiServiceDescriptor,
+ channelFactory,
+ streamObserverFactory);
+ }
+
+ public static void main(
+ PipelineOptions options,
+ Endpoints.ApiServiceDescriptor loggingApiServiceDescriptor,
+ Endpoints.ApiServiceDescriptor controlApiServiceDescriptor,
+ ManagedChannelFactory channelFactory,
+ StreamObserverFactory streamObserverFactory) {
try (BeamFnLoggingClient logging = new BeamFnLoggingClient(
options,
loggingApiServiceDescriptor,
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
