Package org.apache.beam.sdk.io.solace.data

Class Solace

java.lang.Object

org.apache.beam.sdk.io.solace.data.Solace

public class Solace
extends Object

Provides core data models and utilities for working with Solace messages in the context of Apache Beam pipelines. This class includes representations for Solace topics, queues, destinations, and message records, as well as a utility for converting Solace messages into Beam-compatible records.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Solace.CorrelationKey	The correlation key is an object that is passed back to the client during the event broker ack or nack.
static class	Solace.Destination	Represents a Solace message destination (either a Topic or a Queue).
static enum	Solace.DestinationType	Represents a Solace destination type.
static class	Solace.PublishResult	The result of writing a message to Solace.
static class	Solace.Queue	Represents a Solace queue.
static class	Solace.Record	Represents a Solace message record with its associated metadata.
static class	Solace.SolaceRecordMapper	A utility class for mapping BytesXMLMessage instances to Solace.Record objects.
static class	Solace.Topic	Represents a Solace topic.

Constructor Summary

Constructors

Constructor	Description
Solace()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Solace

public Solace()