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

Class Solace.SolaceRecordMapper

java.lang.Object

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

Enclosing class:

Solace

public static class Solace.SolaceRecordMapper
extends Object

A utility class for mapping BytesXMLMessage instances to Solace.Record objects. This simplifies the process of converting raw Solace messages into a format suitable for use within Apache Beam pipelines.

Constructor Summary

Constructors

Constructor	Description
SolaceRecordMapper()

Method Summary

Modifier and Type	Method	Description
static @Nullable Solace.Record	map(@Nullable BytesXMLMessage msg)	Maps a BytesXMLMessage (if not null) to a Solace.Record.

Methods inherited from class java.lang.Object

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

Constructor Details

SolaceRecordMapper

public SolaceRecordMapper()

Method Details

map

public static @Nullable Solace.Record map(@Nullable BytesXMLMessage msg)

Maps a BytesXMLMessage (if not null) to a Solace.Record.

Extracts relevant information from the message, including payload, metadata, and destination details.

Parameters:

msg - The Solace message to map.

Returns:

A Solace Record representing the message, or null if the input message was null.