class Pulsar::Proto::BaseCommand::Type

Constants

ACK
ACK_RESPONSE
ACTIVE_CONSUMER_CHANGE
ADD_PARTITION_TO_TXN
ADD_PARTITION_TO_TXN_RESPONSE
ADD_SUBSCRIPTION_TO_TXN
ADD_SUBSCRIPTION_TO_TXN_RESPONSE
AUTH_CHALLENGE
AUTH_RESPONSE
CLOSE_CONSUMER
CLOSE_PRODUCER
CONNECT
CONNECTED
CONSUMER_STATS
CONSUMER_STATS_RESPONSE
END_TXN
END_TXN_ON_PARTITION
END_TXN_ON_PARTITION_RESPONSE
END_TXN_ON_SUBSCRIPTION
END_TXN_ON_SUBSCRIPTION_RESPONSE
END_TXN_RESPONSE
ERROR
FLOW
GET_LAST_MESSAGE_ID
GET_LAST_MESSAGE_ID_RESPONSE
GET_OR_CREATE_SCHEMA
GET_OR_CREATE_SCHEMA_RESPONSE
GET_SCHEMA
GET_SCHEMA_RESPONSE
GET_TOPICS_OF_NAMESPACE
GET_TOPICS_OF_NAMESPACE_RESPONSE
LOOKUP
LOOKUP_RESPONSE
MESSAGE
NEW_TXN
NEW_TXN_RESPONSE
PARTITIONED_METADATA
PARTITIONED_METADATA_RESPONSE
PING
PONG
PRODUCER
PRODUCER_SUCCESS
REACHED_END_OF_TOPIC
REDELIVER_UNACKNOWLEDGED_MESSAGES
SEEK
SEND
SEND_ERROR
SEND_RECEIPT
SUBSCRIBE
SUCCESS
UNSUBSCRIBE