public static final class PubSubProtocol.PubSubRequest
extends com.google.protobuf.GeneratedMessage
Modifier and Type | Class and Description |
---|---|
static class |
PubSubProtocol.PubSubRequest.Builder |
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessage.ExtendableBuilder>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingType extends com.google.protobuf.Message,Type>
Modifier and Type | Field and Description |
---|---|
static int |
CONSUMEREQUEST_FIELD_NUMBER |
static int |
PROTOCOLVERSION_FIELD_NUMBER |
static int |
PUBLISHREQUEST_FIELD_NUMBER |
static int |
SHOULDCLAIM_FIELD_NUMBER |
static int |
STARTDELIVERYREQUEST_FIELD_NUMBER |
static int |
STOPDELIVERYREQUEST_FIELD_NUMBER |
static int |
SUBSCRIBEREQUEST_FIELD_NUMBER |
static int |
TOPIC_FIELD_NUMBER |
static int |
TRIEDSERVERS_FIELD_NUMBER |
static int |
TXNID_FIELD_NUMBER |
static int |
TYPE_FIELD_NUMBER |
static int |
UNSUBSCRIBEREQUEST_FIELD_NUMBER |
getAllFields, getDescriptorForType, getField, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, newGeneratedExtension
toByteArray, toByteString, writeDelimitedTo, writeTo
public static final int PROTOCOLVERSION_FIELD_NUMBER
public static final int TYPE_FIELD_NUMBER
public static final int TRIEDSERVERS_FIELD_NUMBER
public static final int TXNID_FIELD_NUMBER
public static final int SHOULDCLAIM_FIELD_NUMBER
public static final int TOPIC_FIELD_NUMBER
public static final int PUBLISHREQUEST_FIELD_NUMBER
public static final int SUBSCRIBEREQUEST_FIELD_NUMBER
public static final int CONSUMEREQUEST_FIELD_NUMBER
public static final int UNSUBSCRIBEREQUEST_FIELD_NUMBER
public static final int STOPDELIVERYREQUEST_FIELD_NUMBER
public static final int STARTDELIVERYREQUEST_FIELD_NUMBER
public static PubSubProtocol.PubSubRequest getDefaultInstance()
public PubSubProtocol.PubSubRequest getDefaultInstanceForType()
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessage
public boolean hasProtocolVersion()
public PubSubProtocol.ProtocolVersion getProtocolVersion()
public boolean hasType()
public PubSubProtocol.OperationType getType()
public List<com.google.protobuf.ByteString> getTriedServersList()
public int getTriedServersCount()
public com.google.protobuf.ByteString getTriedServers(int index)
public boolean hasTxnId()
public long getTxnId()
public boolean hasShouldClaim()
public boolean getShouldClaim()
public boolean hasTopic()
public com.google.protobuf.ByteString getTopic()
public boolean hasPublishRequest()
public PubSubProtocol.PublishRequest getPublishRequest()
public boolean hasSubscribeRequest()
public PubSubProtocol.SubscribeRequest getSubscribeRequest()
public boolean hasConsumeRequest()
public PubSubProtocol.ConsumeRequest getConsumeRequest()
public boolean hasUnsubscribeRequest()
public PubSubProtocol.UnsubscribeRequest getUnsubscribeRequest()
public boolean hasStopDeliveryRequest()
public PubSubProtocol.StopDeliveryRequest getStopDeliveryRequest()
public boolean hasStartDeliveryRequest()
public PubSubProtocol.StartDeliveryRequest getStartDeliveryRequest()
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLite
isInitialized
in class com.google.protobuf.GeneratedMessage
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.AbstractMessage
IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.AbstractMessage
public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static PubSubProtocol.PubSubRequest parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static PubSubProtocol.PubSubRequest parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static PubSubProtocol.PubSubRequest parseFrom(InputStream input) throws IOException
IOException
public static PubSubProtocol.PubSubRequest parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static PubSubProtocol.PubSubRequest parseDelimitedFrom(InputStream input) throws IOException
IOException
public static PubSubProtocol.PubSubRequest parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static PubSubProtocol.PubSubRequest.Builder newBuilder()
public PubSubProtocol.PubSubRequest.Builder newBuilderForType()
public static PubSubProtocol.PubSubRequest.Builder newBuilder(PubSubProtocol.PubSubRequest prototype)
public PubSubProtocol.PubSubRequest.Builder toBuilder()
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.