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

Class Solace

java.lang.Object

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

public class Solace
extends java.lang.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 and 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 class	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 and Description
Solace()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

Solace

public Solace()