Package org.apache.beam.sdk.io.solace.data
package org.apache.beam.sdk.io.solace.data
Solace IO connector - data-related classes.
-
ClassDescriptionProvides core data models and utilities for working with Solace messages in the context of Apache Beam pipelines.The correlation key is an object that is passed back to the client during the event broker ack or nack.Represents a Solace message destination (either a Topic or a Queue).Represents a Solace destination type.The result of writing a message to Solace.Represents a Solace queue.Represents a Solace message record with its associated metadata.A utility class for mapping
BytesXMLMessageinstances toSolace.Recordobjects.Represents a Solace topic.