Package org.apache.beam.sdk.io.pulsar

Class PulsarMessage

java.lang.Object

org.apache.beam.sdk.io.pulsar.PulsarMessage

public class PulsarMessage
extends Object

Class representing a Pulsar Message record. Each PulsarMessage contains a single message basic message data and Message record to access directly.

Constructor Summary

Constructors

Constructor	Description
PulsarMessage(String topic, Long publishTimestamp)
PulsarMessage(String topic, Long publishTimestamp, Object messageRecord)

Method Summary

Modifier and Type	Method	Description
Object	getMessageRecord()
Long	getPublishTimestamp()
String	getTopic()
void	setMessageRecord(Object messageRecord)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarMessage

public PulsarMessage(String topic,
 Long publishTimestamp,
 Object messageRecord)

PulsarMessage

public PulsarMessage(String topic,
 Long publishTimestamp)

Method Details

getTopic

public String getTopic()

getPublishTimestamp

public Long getPublishTimestamp()

setMessageRecord

public void setMessageRecord(Object messageRecord)

getMessageRecord

public Object getMessageRecord()