Class PulsarHeaders

java.lang.Object

org.apache.pulsar.spring.support.PulsarHeaders

public abstract class PulsarHeaders
extends Object

Pulsar specific message headers.

Author:

Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BROKER_PUBLISH_TIME	Broker publish time (long).
static final String	EVENT_TIME	Event time (long).
static final String	INDEX	Message index if available.
static final String	KEY	Message key if present.
static final String	KEY_BYTES	Message key as bytes if present.
static final String	MESSAGE_ID	Unique message id.
static final String	MESSAGE_SIZE	Message size in bytes.
static final String	ORDERING_KEY	Message ordering key.
static final String	PREFIX	The prefix for Pulsar headers.
static final String	PRODUCER_NAME	Producer name.
static final String	PUBLISH_TIME	Message publish time (long).
static final String	PULSAR_MESSAGE	The prefix for the message.
static final String	RAW_DATA	Raw message data as bytes.
static final String	REDELIVERY_COUNT	Redelivery count.
static final String	REPLICATED_FROM	Cluster where the message is replicated from.
static final String	SCHEMA_VERSION	Schema version.
static final String	SEQUENCE_ID	Message sequence id.
static final String	TOPIC_NAME	Topic name.

Constructor Summary

Constructors

Constructor	Description
PulsarHeaders()

Method Summary

Methods inherited from class Object

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

Field Details

PREFIX

public static final String PREFIX

The prefix for Pulsar headers.

See Also:

• Constant Field Values

PULSAR_MESSAGE

public static final String PULSAR_MESSAGE

The prefix for the message.

See Also:

• Constant Field Values

MESSAGE_ID

public static final String MESSAGE_ID

Unique message id.

See Also:

• Constant Field Values

RAW_DATA

public static final String RAW_DATA

Raw message data as bytes.

See Also:

• Constant Field Values

MESSAGE_SIZE

public static final String MESSAGE_SIZE

Message size in bytes.

See Also:

• Constant Field Values

PUBLISH_TIME

public static final String PUBLISH_TIME

Message publish time (long).

See Also:

• Constant Field Values

EVENT_TIME

public static final String EVENT_TIME

Event time (long).

See Also:

• Constant Field Values

SEQUENCE_ID

public static final String SEQUENCE_ID

Message sequence id.

See Also:

• Constant Field Values

PRODUCER_NAME

public static final String PRODUCER_NAME

Producer name.

See Also:

• Constant Field Values

KEY

public static final String KEY

Message key if present.

See Also:

• Constant Field Values

KEY_BYTES

public static final String KEY_BYTES

Message key as bytes if present.

See Also:

• Constant Field Values

ORDERING_KEY

public static final String ORDERING_KEY

Message ordering key.

See Also:

• Constant Field Values

TOPIC_NAME

public static final String TOPIC_NAME

Topic name.

See Also:

• Constant Field Values

REDELIVERY_COUNT

public static final String REDELIVERY_COUNT

Redelivery count.

See Also:

• Constant Field Values

SCHEMA_VERSION

public static final String SCHEMA_VERSION

Schema version.

See Also:

• Constant Field Values

REPLICATED_FROM

public static final String REPLICATED_FROM

Cluster where the message is replicated from.

See Also:

• Constant Field Values

BROKER_PUBLISH_TIME

public static final String BROKER_PUBLISH_TIME

Broker publish time (long).

See Also:

• Constant Field Values

INDEX

public static final String INDEX

Message index if available.

See Also:

• Constant Field Values

Constructor Details

PulsarHeaders

public PulsarHeaders()