org.apache.hedwig.protocol

Class PubSubProtocol.PubSubRequest

java.lang.Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite

Enclosing class:

PubSubProtocol

public static final class PubSubProtocol.PubSubRequest
extends com.google.protobuf.GeneratedMessage

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubSubProtocol.PubSubRequest.Builder

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage

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>

Field Summary

Fields

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

Method Summary

Methods

Modifier and Type	Method and Description
PubSubProtocol.ConsumeRequest	getConsumeRequest()
static PubSubProtocol.PubSubRequest	getDefaultInstance()
PubSubProtocol.PubSubRequest	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
PubSubProtocol.ProtocolVersion	getProtocolVersion()
PubSubProtocol.PublishRequest	getPublishRequest()
int	getSerializedSize()
boolean	getShouldClaim()
PubSubProtocol.StartDeliveryRequest	getStartDeliveryRequest()
PubSubProtocol.StopDeliveryRequest	getStopDeliveryRequest()
PubSubProtocol.SubscribeRequest	getSubscribeRequest()
com.google.protobuf.ByteString	getTopic()
com.google.protobuf.ByteString	getTriedServers(int index)
int	getTriedServersCount()
List<com.google.protobuf.ByteString>	getTriedServersList()
long	getTxnId()
PubSubProtocol.OperationType	getType()
PubSubProtocol.UnsubscribeRequest	getUnsubscribeRequest()
boolean	hasConsumeRequest()
boolean	hasProtocolVersion()
boolean	hasPublishRequest()
boolean	hasShouldClaim()
boolean	hasStartDeliveryRequest()
boolean	hasStopDeliveryRequest()
boolean	hasSubscribeRequest()
boolean	hasTopic()
boolean	hasTxnId()
boolean	hasType()
boolean	hasUnsubscribeRequest()
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
static PubSubProtocol.PubSubRequest.Builder	newBuilder()
static PubSubProtocol.PubSubRequest.Builder	newBuilder(PubSubProtocol.PubSubRequest prototype)
PubSubProtocol.PubSubRequest.Builder	newBuilderForType()
static PubSubProtocol.PubSubRequest	parseDelimitedFrom(InputStream input)
static PubSubProtocol.PubSubRequest	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubProtocol.PubSubRequest	parseFrom(byte[] data)
static PubSubProtocol.PubSubRequest	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubProtocol.PubSubRequest	parseFrom(com.google.protobuf.ByteString data)
static PubSubProtocol.PubSubRequest	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubProtocol.PubSubRequest	parseFrom(com.google.protobuf.CodedInputStream input)
static PubSubProtocol.PubSubRequest	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubProtocol.PubSubRequest	parseFrom(InputStream input)
static PubSubProtocol.PubSubRequest	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
PubSubProtocol.PubSubRequest.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessage

getAllFields, getDescriptorForType, getField, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, newGeneratedExtension

Methods inherited from class com.google.protobuf.AbstractMessage

equals, hashCode, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Field Detail

PROTOCOLVERSION_FIELD_NUMBER

public static final int PROTOCOLVERSION_FIELD_NUMBER

See Also:

Constant Field Values

TYPE_FIELD_NUMBER

public static final int TYPE_FIELD_NUMBER

See Also:

Constant Field Values

TRIEDSERVERS_FIELD_NUMBER

public static final int TRIEDSERVERS_FIELD_NUMBER

See Also:

Constant Field Values

TXNID_FIELD_NUMBER

public static final int TXNID_FIELD_NUMBER

See Also:

Constant Field Values

SHOULDCLAIM_FIELD_NUMBER

public static final int SHOULDCLAIM_FIELD_NUMBER

See Also:

Constant Field Values

TOPIC_FIELD_NUMBER

public static final int TOPIC_FIELD_NUMBER

See Also:

Constant Field Values

PUBLISHREQUEST_FIELD_NUMBER

public static final int PUBLISHREQUEST_FIELD_NUMBER

See Also:

Constant Field Values

SUBSCRIBEREQUEST_FIELD_NUMBER

public static final int SUBSCRIBEREQUEST_FIELD_NUMBER

See Also:

Constant Field Values

CONSUMEREQUEST_FIELD_NUMBER

public static final int CONSUMEREQUEST_FIELD_NUMBER

See Also:

Constant Field Values

UNSUBSCRIBEREQUEST_FIELD_NUMBER

public static final int UNSUBSCRIBEREQUEST_FIELD_NUMBER

See Also:

Constant Field Values

STOPDELIVERYREQUEST_FIELD_NUMBER

public static final int STOPDELIVERYREQUEST_FIELD_NUMBER

See Also:

Constant Field Values

STARTDELIVERYREQUEST_FIELD_NUMBER

public static final int STARTDELIVERYREQUEST_FIELD_NUMBER

See Also:

Constant Field Values

Method Detail

getDefaultInstance

public static PubSubProtocol.PubSubRequest getDefaultInstance()

getDefaultInstanceForType

public PubSubProtocol.PubSubRequest getDefaultInstanceForType()

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

hasProtocolVersion

public boolean hasProtocolVersion()

getProtocolVersion

public PubSubProtocol.ProtocolVersion getProtocolVersion()

hasType

public boolean hasType()

getType

public PubSubProtocol.OperationType getType()

getTriedServersList

public List<com.google.protobuf.ByteString> getTriedServersList()

getTriedServersCount

public int getTriedServersCount()

getTriedServers

public com.google.protobuf.ByteString getTriedServers(int index)

hasTxnId

public boolean hasTxnId()

getTxnId

public long getTxnId()

hasShouldClaim

public boolean hasShouldClaim()

getShouldClaim

public boolean getShouldClaim()

hasTopic

public boolean hasTopic()

getTopic

public com.google.protobuf.ByteString getTopic()

hasPublishRequest

public boolean hasPublishRequest()

getPublishRequest

public PubSubProtocol.PublishRequest getPublishRequest()

hasSubscribeRequest

public boolean hasSubscribeRequest()

getSubscribeRequest

public PubSubProtocol.SubscribeRequest getSubscribeRequest()

hasConsumeRequest

public boolean hasConsumeRequest()

getConsumeRequest

public PubSubProtocol.ConsumeRequest getConsumeRequest()

hasUnsubscribeRequest

public boolean hasUnsubscribeRequest()

getUnsubscribeRequest

public PubSubProtocol.UnsubscribeRequest getUnsubscribeRequest()

hasStopDeliveryRequest

public boolean hasStopDeliveryRequest()

getStopDeliveryRequest

public PubSubProtocol.StopDeliveryRequest getStopDeliveryRequest()

hasStartDeliveryRequest

public boolean hasStartDeliveryRequest()

getStartDeliveryRequest

public PubSubProtocol.StartDeliveryRequest getStartDeliveryRequest()

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLite

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.AbstractMessage

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.AbstractMessage

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.ByteString data)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.ByteString data,
                                     com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(byte[] data)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(byte[] data,
                                     com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(InputStream input)
                                              throws IOException

Throws:

IOException

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(InputStream input,
                                     com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws IOException

Throws:

IOException

parseDelimitedFrom

public static PubSubProtocol.PubSubRequest parseDelimitedFrom(InputStream input)
                                                       throws IOException

Throws:

IOException

parseDelimitedFrom

public static PubSubProtocol.PubSubRequest parseDelimitedFrom(InputStream input,
                                              com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                       throws IOException

Throws:

IOException

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.CodedInputStream input)
                                              throws IOException

Throws:

IOException

parseFrom

public static PubSubProtocol.PubSubRequest parseFrom(com.google.protobuf.CodedInputStream input,
                                     com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws IOException

Throws:

IOException

newBuilder

public static PubSubProtocol.PubSubRequest.Builder newBuilder()

newBuilderForType

public PubSubProtocol.PubSubRequest.Builder newBuilderForType()

newBuilder

public static PubSubProtocol.PubSubRequest.Builder newBuilder(PubSubProtocol.PubSubRequest prototype)

toBuilder

public PubSubProtocol.PubSubRequest.Builder toBuilder()