org.apache.pulsar.common.api.proto

Interface PulsarApi.CommandSubscribeOrBuilder

All Superinterfaces:

org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder

All Known Implementing Classes:

PulsarApi.CommandSubscribe, PulsarApi.CommandSubscribe.Builder

Enclosing class:

PulsarApi

public static interface PulsarApi.CommandSubscribeOrBuilder
extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder

Method Summary

Modifier and Type	Method and Description
long	getConsumerId()
String	getConsumerName()
boolean	getDurable()
PulsarApi.CommandSubscribe.InitialPosition	getInitialPosition()
PulsarApi.KeyValue	getMetadata(int index)
int	getMetadataCount()
List<PulsarApi.KeyValue>	getMetadataList()
int	getPriorityLevel()
boolean	getReadCompacted()
long	getRequestId()
PulsarApi.Schema	getSchema()
PulsarApi.MessageIdData	getStartMessageId()
String	getSubscription()
PulsarApi.CommandSubscribe.SubType	getSubType()
String	getTopic()
boolean	hasConsumerId()
boolean	hasConsumerName()
boolean	hasDurable()
boolean	hasInitialPosition()
boolean	hasPriorityLevel()
boolean	hasReadCompacted()
boolean	hasRequestId()
boolean	hasSchema()
boolean	hasStartMessageId()
boolean	hasSubscription()
boolean	hasSubType()
boolean	hasTopic()

Methods inherited from interface org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder

getDefaultInstanceForType, isInitialized

Method Detail

hasTopic

boolean hasTopic()

getTopic

String getTopic()

hasSubscription

boolean hasSubscription()

getSubscription

String getSubscription()

hasSubType

boolean hasSubType()

getSubType

PulsarApi.CommandSubscribe.SubType getSubType()

hasConsumerId

boolean hasConsumerId()

getConsumerId

long getConsumerId()

hasRequestId

boolean hasRequestId()

getRequestId

long getRequestId()

hasConsumerName

boolean hasConsumerName()

getConsumerName

String getConsumerName()

hasPriorityLevel

boolean hasPriorityLevel()

getPriorityLevel

int getPriorityLevel()

hasDurable

boolean hasDurable()

getDurable

boolean getDurable()

hasStartMessageId

boolean hasStartMessageId()

getStartMessageId

PulsarApi.MessageIdData getStartMessageId()

getMetadataList

List<PulsarApi.KeyValue> getMetadataList()

getMetadata

PulsarApi.KeyValue getMetadata(int index)

getMetadataCount

int getMetadataCount()

hasReadCompacted

boolean hasReadCompacted()

getReadCompacted

boolean getReadCompacted()

hasSchema

boolean hasSchema()

getSchema

PulsarApi.Schema getSchema()

hasInitialPosition

boolean hasInitialPosition()

getInitialPosition

PulsarApi.CommandSubscribe.InitialPosition getInitialPosition()