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(value=AutoValueSchema.class)
public abstract static class Solace.CorrelationKey
extends java.lang.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 and Description
static class	Solace.CorrelationKey.Builder

Constructor Summary

Constructors

Constructor and Description
CorrelationKey()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

CorrelationKey

public CorrelationKey()

Method Detail

getMessageId

@SchemaFieldNumber(value="0")
public abstract java.lang.String getMessageId()

getPublishMonotonicNanos

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

builder

public static Solace.CorrelationKey.Builder builder()