Package com.solace.serdes.common.resolver.strategy

Class DestinationIdStrategy<T,S>

java.lang.Object

com.solace.serdes.common.resolver.strategy.DestinationIdStrategy<T,S>

Type Parameters:

T - The type of object to be serialized/deserialized

S - The type of schema

All Implemented Interfaces:

ArtifactReferenceResolverStrategy<T,S>

Direct Known Subclasses:

SolaceTopicIdStrategy

public class DestinationIdStrategy<T,S>
extends Object
implements ArtifactReferenceResolverStrategy<T,S>

A strategy for resolving artifact references based on destination names.

This strategy uses the destination name from the record's metadata as the artifact ID and uses the default group ID. It requires that the record's metadata and destination name are non-null and non-empty.

Constructor Summary

Constructors

Constructor	Description
DestinationIdStrategy()	Constructs a DestinationIdStrategy.

Method Summary

Modifier and Type	Method	Description
ArtifactReference	artifactReference(Record<T> data, ParsedSchema<S> parsedSchema)	Resolves and returns the ArtifactReference for a given record.
boolean	loadSchema()	Determines whether to load and provide the parsed schema to the ArtifactReferenceResolverStrategy.artifactReference(Record, ParsedSchema) method.

Methods inherited from class java.lang.Object

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

Constructor Detail

DestinationIdStrategy

public DestinationIdStrategy()

Constructs a DestinationIdStrategy.

Method Detail

artifactReference

public ArtifactReference artifactReference(Record<T> data,
                                           ParsedSchema<S> parsedSchema)

Description copied from interface: ArtifactReferenceResolverStrategy

Resolves and returns the ArtifactReference for a given record. This ArtifactReference indicates where the schema is located or should be registered within the registry.

Specified by:

artifactReference in interface ArtifactReferenceResolverStrategy<T,S>

Parameters:

data - The record for which to resolve the ArtifactReference.

parsedSchema - The schema of the record being resolved. This can be null if ArtifactReferenceResolverStrategy.loadSchema() returns false.

Returns:

The ArtifactReference under which the schema is located or should be registered.

loadSchema

public boolean loadSchema()

Description copied from interface: ArtifactReferenceResolverStrategy

Determines whether to load and provide the parsed schema to the ArtifactReferenceResolverStrategy.artifactReference(Record, ParsedSchema) method.

Specified by:

loadSchema in interface ArtifactReferenceResolverStrategy<T,S>

Returns:

true if the schema should be loaded and passed, false otherwise. Default implementation returns true.