Package org.apache.beam.sdk.io.solace.broker
package org.apache.beam.sdk.io.solace.broker
Solace IO broker-related classes.
-
ClassDescriptionA factory for creating
JcsmpSessionServiceinstances.A class that manages REST calls to the Solace Element Management Protocol (SEMP) using basic authentication.A factory for creatingBasicAuthSempClientinstances.This class implements aSessionServiceFactorythat retrieve the basic authentication credentials from a Google Cloud Secret Manager secret.A class that manages a connection to a Solace broker using basic authentication.Base class for publishing messages to a Solace broker.Interface for receiving messages from a Solace broker.This class is required to handle callbacks from Solace, to find out if messages were actually published or there were any kind of error.A class to execute requests to SEMP v2 with Basic Auth authentication.This interface defines methods for interacting with a Solace message broker using the Solace Element Management Protocol (SEMP).This interface serves as a blueprint for creating SempClient objects, which are used to interact with a Solace message broker using the Solace Element Management Protocol (SEMP).The SessionService interface provides a set of methods for managing a session with the Solace messaging system.This abstract class serves as a blueprint for creating `SessionServiceFactory` objects.