(beam) branch master updated (ef885399c92 -> 96b9de0fee9)

[yh...@apache.org]

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 ef885399c92 CassandraIO: Fix generic SelectAll clauses provided by ValueProvider<String> causing CassandraIO.read to fail (#31623)
     add 96b9de0fee9 Solace Read connector: UnboundedSource and UnboundedReader (#31636)

No new revisions were added by this update.

Summary of changes:
 sdks/java/io/solace/build.gradle                   |   3 +
 .../beam/sdk/io/solace/broker/MessageReceiver.java |  59 +++++++
 .../beam/sdk/io/solace/broker/SempClient.java      |  49 ++++++
 .../sdk/io/solace/broker/SempClientFactory.java    |  11 +-
 .../beam/sdk/io/solace/broker/SessionService.java  |  50 ++++++
 .../io/solace/broker/SessionServiceFactory.java    |   9 +-
 .../sdk/io/solace/read/SolaceCheckpointMark.java   |   6 +-
 .../sdk/io/solace/read/UnboundedSolaceReader.java  | 191 +++++++++++++++++++++
 .../sdk/io/solace/read/UnboundedSolaceSource.java  | 148 ++++++++++++++++
 9 files changed, 523 insertions(+), 3 deletions(-)
 create mode 100644 sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/MessageReceiver.java
 create mode 100644 sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempClient.java
 create mode 100644 sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SessionService.java
 create mode 100644 sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/UnboundedSolaceReader.java
 create mode 100644 sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/UnboundedSolaceSource.java