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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and 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(java.lang.String messageId)
abstract Solace.Record.Builder	setPayload(byte[] payload)
abstract Solace.Record.Builder	setPriority(int priority)
abstract Solace.Record.Builder	setReceiveTimestamp(@Nullable java.lang.Long receiveTimestamp)
abstract Solace.Record.Builder	setRedelivered(boolean redelivered)
abstract Solace.Record.Builder	setReplicationGroupMessageId(@Nullable java.lang.String replicationGroupMessageId)
abstract Solace.Record.Builder	setReplyTo(@Nullable Solace.Destination replyTo)
abstract Solace.Record.Builder	setSenderTimestamp(@Nullable java.lang.Long senderTimestamp)
abstract Solace.Record.Builder	setSequenceNumber(@Nullable java.lang.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 Detail

Builder

public Builder()

Method Detail

setMessageId

public abstract Solace.Record.Builder setMessageId(java.lang.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 java.lang.Long receiveTimestamp)

setSenderTimestamp

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

setSequenceNumber

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

setTimeToLive

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

setReplicationGroupMessageId

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

setAttachmentBytes

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

build

public abstract Solace.Record build()