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

Class Solace.PublishResult

java.lang.Object

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

Enclosing class:

Solace

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class Solace.PublishResult
extends java.lang.Object

The result of writing a message to Solace. This will be returned by the com.google.cloud.dataflow.dce.io.solace.SolaceIO.Write connector.

This class provides a builder to create instances, but you will probably not need it. The write connector will create and return instances of Solace.PublishResult.

If the message has been published, getPublished() will be true. If it is false, it means that the message could not be published, and getError() will contain more details about why the message could not be published.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
PublishResult()

Method Summary

Modifier and Type	Method and Description
static Solace.PublishResult.Builder	builder()
abstract @Nullable java.lang.String	getError() The error details if the message could not be published.
abstract @Nullable java.lang.Long	getLatencyMilliseconds() The publishing latency in milliseconds.
abstract java.lang.String	getMessageId() The message id of the message that was published.
abstract java.lang.Boolean	getPublished() Whether the message was published or not.

Methods inherited from class java.lang.Object

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

Constructor Detail

PublishResult

public PublishResult()

Method Detail

getMessageId

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

The message id of the message that was published.

getPublished

@SchemaFieldNumber(value="1")
public abstract java.lang.Boolean getPublished()

Whether the message was published or not.

getLatencyMilliseconds

@SchemaFieldNumber(value="2")
public abstract @Nullable java.lang.Long getLatencyMilliseconds()

The publishing latency in milliseconds. This is the difference between the time the message was created, and the time the message was published. It is only available if the Solace.CorrelationKey class is used as correlation key of the messages.

getError

@SchemaFieldNumber(value="3")
public abstract @Nullable java.lang.String getError()

The error details if the message could not be published.

builder

public static Solace.PublishResult.Builder builder()