This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 96962011e7e Unpin Dataflow legacy worker container for Nexmark test
(#33224)
add 9560fe1d18e SolaceIO: refactor to allow inheritance of
BasicAuthSempClient (#32400)
No new revisions were added by this update.
Summary of changes:
.../sdk/io/solace/broker/BasicAuthSempClient.java | 31 ++------
.../solace/broker/SempBasicAuthClientExecutor.java | 35 ++++++++-
.../beam/sdk/io/solace/write/AddShardKeyDoFn.java | 5 +-
.../io/solace/it/BasicAuthMultipleSempClient.java | 62 ++++++++++++++++
.../it/BasicAuthMultipleSempClientFactory.java} | 50 +++++++------
...SolaceIOIT.java => SolaceIOMultipleSempIT.java} | 83 +++++++++-------------
6 files changed, 169 insertions(+), 97 deletions(-)
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/BasicAuthMultipleSempClient.java
copy
sdks/java/io/solace/src/{main/java/org/apache/beam/sdk/io/solace/broker/BasicAuthSempClientFactory.java
=>
test/java/org/apache/beam/sdk/io/solace/it/BasicAuthMultipleSempClientFactory.java}
(57%)
copy
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/{SolaceIOIT.java
=> SolaceIOMultipleSempIT.java} (78%)