Skip to content

Commit c511260

Browse files
authored
make pulsar getters public (#37169)
1 parent e655f5c commit c511260

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -31,19 +31,19 @@
3131
@DefaultSchema(AutoValueSchema.class)
3232
@AutoValue
3333
public abstract class PulsarMessage {
34-
abstract @Nullable String getTopic();
34+
public abstract @Nullable String getTopic();
3535

36-
abstract long getPublishTimestamp();
36+
public abstract long getPublishTimestamp();
3737

38-
abstract @Nullable String getKey();
38+
public abstract @Nullable String getKey();
3939

4040
@SuppressWarnings("mutable")
41-
abstract byte[] getValue();
41+
public abstract byte[] getValue();
4242

43-
abstract @Nullable Map<String, String> getProperties();
43+
public abstract @Nullable Map<String, String> getProperties();
4444

4545
@SuppressWarnings("mutable")
46-
abstract byte[] getMessageId();
46+
public abstract byte[] getMessageId();
4747

4848
public static PulsarMessage create(
4949
@Nullable String topicName,

0 commit comments

Comments
 (0)