PubSubProtocol.StatusCode code
Collection<E> exceptions
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString subscriberId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString subscriberId_
PubSubProtocol.MessageSeqId msgId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
Object hostname_
long czxid_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
long numTopics_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
long ledgerId_
PubSubProtocol.MessageSeqId endSeqIdIncluded_
long startSeqIdIncluded_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
Object managerImpl_
int managerVersion_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
Object key_
com.google.protobuf.ByteString value_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString body_
com.google.protobuf.ByteString srcRegion_
PubSubProtocol.MessageSeqId msgId_
PubSubProtocol.MessageHeader header_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.Map properties_
Object messageType_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.Message msg_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.MessageSeqId publishedMsgId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.ProtocolVersion protocolVersion_
PubSubProtocol.OperationType type_
List<E> triedServers_
long txnId_
boolean shouldClaim_
com.google.protobuf.ByteString topic_
PubSubProtocol.PublishRequest publishRequest_
PubSubProtocol.SubscribeRequest subscribeRequest_
PubSubProtocol.ConsumeRequest consumeRequest_
PubSubProtocol.UnsubscribeRequest unsubscribeRequest_
PubSubProtocol.StopDeliveryRequest stopDeliveryRequest_
PubSubProtocol.StartDeliveryRequest startDeliveryRequest_
PubSubProtocol.CloseSubscriptionRequest closeSubscriptionRequest_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.ProtocolVersion protocolVersion_
PubSubProtocol.StatusCode statusCode_
long txnId_
Object statusMsg_
PubSubProtocol.Message message_
com.google.protobuf.ByteString topic_
com.google.protobuf.ByteString subscriberId_
PubSubProtocol.ResponseBody responseBody_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString region_
long seqId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.PublishResponse publishResponse_
PubSubProtocol.SubscribeResponse subscribeResponse_
PubSubProtocol.SubscriptionEventResponse subscriptionEvent_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString subscriberId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString subscriberId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString subscriberId_
PubSubProtocol.SubscribeRequest.CreateOrAttach createOrAttach_
boolean synchronous_
int messageBound_
PubSubProtocol.SubscriptionPreferences preferences_
boolean forceAttach_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.SubscriptionPreferences preferences_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.SubscriptionState state_
PubSubProtocol.SubscriptionPreferences preferences_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.SubscriptionEvent event_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
boolean forceAttach_
PubSubProtocol.SubscribeRequest.CreateOrAttach createOrAttach_
int messageBound_
PubSubProtocol.Map options_
Object messageFilter_
int messageWindowSize_
boolean enableResubscribe_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.Map options_
int messageBound_
Object messageFilter_
int messageWindowSize_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
PubSubProtocol.MessageSeqId msgId_
int messageBound_
byte memoizedIsInitialized
int memoizedSerializedSize
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException
int bitField0_
com.google.protobuf.ByteString subscriberId_
byte memoizedIsInitialized
int memoizedSerializedSize
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.