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

Class Solace.Record.Builder

java.lang.Object

org.apache.beam.sdk.io.solace.data.Solace.Record.Builder

Enclosing class:

Solace.Record

public abstract static class Solace.Record.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract Solace.Record	build()
abstract Solace.Record.Builder	setAttachmentBytes(byte[] attachmentBytes)
abstract Solace.Record.Builder	setDestination(@Nullable Solace.Destination destination)
abstract Solace.Record.Builder	setExpiration(long expiration)
abstract Solace.Record.Builder	setMessageId(String messageId)
abstract Solace.Record.Builder	setPayload(byte[] payload)
abstract Solace.Record.Builder	setPriority(int priority)
abstract Solace.Record.Builder	setReceiveTimestamp(@Nullable Long receiveTimestamp)
abstract Solace.Record.Builder	setRedelivered(boolean redelivered)
abstract Solace.Record.Builder	setReplicationGroupMessageId(@Nullable String replicationGroupMessageId)
abstract Solace.Record.Builder	setReplyTo(@Nullable Solace.Destination replyTo)
abstract Solace.Record.Builder	setSenderTimestamp(@Nullable Long senderTimestamp)
abstract Solace.Record.Builder	setSequenceNumber(@Nullable Long sequenceNumber)
abstract Solace.Record.Builder	setTimeToLive(long timeToLive)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setMessageId

public abstract Solace.Record.Builder setMessageId(String messageId)

setPayload

public abstract Solace.Record.Builder setPayload(byte[] payload)

setDestination

public abstract Solace.Record.Builder setDestination(@Nullable Solace.Destination destination)

setExpiration

public abstract Solace.Record.Builder setExpiration(long expiration)

setPriority

public abstract Solace.Record.Builder setPriority(int priority)

setRedelivered

public abstract Solace.Record.Builder setRedelivered(boolean redelivered)

setReplyTo

public abstract Solace.Record.Builder setReplyTo(@Nullable Solace.Destination replyTo)

setReceiveTimestamp

public abstract Solace.Record.Builder setReceiveTimestamp(@Nullable Long receiveTimestamp)

setSenderTimestamp

public abstract Solace.Record.Builder setSenderTimestamp(@Nullable Long senderTimestamp)

setSequenceNumber

public abstract Solace.Record.Builder setSequenceNumber(@Nullable Long sequenceNumber)

setTimeToLive

public abstract Solace.Record.Builder setTimeToLive(long timeToLive)

setReplicationGroupMessageId

public abstract Solace.Record.Builder setReplicationGroupMessageId(@Nullable String replicationGroupMessageId)

setAttachmentBytes

public abstract Solace.Record.Builder setAttachmentBytes(byte[] attachmentBytes)

build

public abstract Solace.Record build()