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

Class Solace.CorrelationKey

java.lang.Object

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

Enclosing class:

Solace

@DefaultSchema(AutoValueSchema.class)
public abstract static class Solace.CorrelationKey
extends Object

The correlation key is an object that is passed back to the client during the event broker ack or nack.

In the streaming writer is optionally used to calculate publish latencies, by calculating the time difference between the creation of the correlation key, and the time of the ack.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Solace.CorrelationKey.Builder

Constructor Summary

Constructors

Constructor	Description
CorrelationKey()

Method Summary

Modifier and Type	Method	Description
static Solace.CorrelationKey.Builder	builder()
abstract String	getMessageId()
abstract long	getPublishMonotonicNanos()

Methods inherited from class java.lang.Object

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

Constructor Details

CorrelationKey

public CorrelationKey()

Method Details

getMessageId

@SchemaFieldNumber("0")
public abstract String getMessageId()

getPublishMonotonicNanos

@SchemaFieldNumber("1")
public abstract long getPublishMonotonicNanos()

builder

public static Solace.CorrelationKey.Builder builder()