- CONNECT =
value(:CONNECT, 2)
- CONNECTED =
value(:CONNECTED, 3)
- SUBSCRIBE =
value(:SUBSCRIBE, 4)
- PRODUCER =
value(:PRODUCER, 5)
- SEND =
value(:SEND, 6)
- SEND_RECEIPT =
value(:SEND_RECEIPT, 7)
- SEND_ERROR =
value(:SEND_ERROR, 8)
- MESSAGE =
value(:MESSAGE, 9)
- ACK =
value(:ACK, 10)
- FLOW =
value(:FLOW, 11)
- UNSUBSCRIBE =
value(:UNSUBSCRIBE, 12)
- SUCCESS =
value(:SUCCESS, 13)
- ERROR =
value(:ERROR, 14)
- CLOSE_PRODUCER =
value(:CLOSE_PRODUCER, 15)
- CLOSE_CONSUMER =
value(:CLOSE_CONSUMER, 16)
- PRODUCER_SUCCESS =
value(:PRODUCER_SUCCESS, 17)
- PING =
value(:PING, 18)
- PONG =
value(:PONG, 19)
- REDELIVER_UNACKNOWLEDGED_MESSAGES =
value(:REDELIVER_UNACKNOWLEDGED_MESSAGES, 20)
- PARTITIONED_METADATA =
value(:PARTITIONED_METADATA, 21)
- PARTITIONED_METADATA_RESPONSE =
value(:PARTITIONED_METADATA_RESPONSE, 22)
- LOOKUP =
value(:LOOKUP, 23)
- LOOKUP_RESPONSE =
value(:LOOKUP_RESPONSE, 24)
- CONSUMER_STATS =
value(:CONSUMER_STATS, 25)
- CONSUMER_STATS_RESPONSE =
value(:CONSUMER_STATS_RESPONSE, 26)
- REACHED_END_OF_TOPIC =
value(:REACHED_END_OF_TOPIC, 27)
- SEEK =
value(:SEEK, 28)
- GET_LAST_MESSAGE_ID =
value(:GET_LAST_MESSAGE_ID, 29)
- GET_LAST_MESSAGE_ID_RESPONSE =
value(:GET_LAST_MESSAGE_ID_RESPONSE, 30)
- ACTIVE_CONSUMER_CHANGE =
value(:ACTIVE_CONSUMER_CHANGE, 31)
- GET_TOPICS_OF_NAMESPACE =
value(:GET_TOPICS_OF_NAMESPACE, 32)
- GET_TOPICS_OF_NAMESPACE_RESPONSE =
value(:GET_TOPICS_OF_NAMESPACE_RESPONSE, 33)
- GET_SCHEMA =
value(:GET_SCHEMA, 34)
- GET_SCHEMA_RESPONSE =
value(:GET_SCHEMA_RESPONSE, 35)
- AUTH_CHALLENGE =
value(:AUTH_CHALLENGE, 36)
- AUTH_RESPONSE =
value(:AUTH_RESPONSE, 37)
- ACK_RESPONSE =
value(:ACK_RESPONSE, 38)
- GET_OR_CREATE_SCHEMA =
value(:GET_OR_CREATE_SCHEMA, 39)
- GET_OR_CREATE_SCHEMA_RESPONSE =
value(:GET_OR_CREATE_SCHEMA_RESPONSE, 40)
- NEW_TXN =
value(:NEW_TXN, 50)
- NEW_TXN_RESPONSE =
value(:NEW_TXN_RESPONSE, 51)
- ADD_PARTITION_TO_TXN =
value(:ADD_PARTITION_TO_TXN, 52)
- ADD_PARTITION_TO_TXN_RESPONSE =
value(:ADD_PARTITION_TO_TXN_RESPONSE, 53)
- ADD_SUBSCRIPTION_TO_TXN =
value(:ADD_SUBSCRIPTION_TO_TXN, 54)
- ADD_SUBSCRIPTION_TO_TXN_RESPONSE =
value(:ADD_SUBSCRIPTION_TO_TXN_RESPONSE, 55)
- END_TXN =
value(:END_TXN, 56)
- END_TXN_RESPONSE =
value(:END_TXN_RESPONSE, 57)
- END_TXN_ON_PARTITION =
value(:END_TXN_ON_PARTITION, 58)
- END_TXN_ON_PARTITION_RESPONSE =
value(:END_TXN_ON_PARTITION_RESPONSE, 59)
- END_TXN_ON_SUBSCRIPTION =
value(:END_TXN_ON_SUBSCRIPTION, 60)
- END_TXN_ON_SUBSCRIPTION_RESPONSE =
value(:END_TXN_ON_SUBSCRIPTION_RESPONSE, 61)