org.apache.hedwig.protocol

Class PubSubProtocol.PubSubRequest.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder<BuilderType>

com.google.protobuf.AbstractMessage.Builder<BuilderType>

com.google.protobuf.GeneratedMessage.Builder<PubSubProtocol.PubSubRequest.Builder>

org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, PubSubProtocol.PubSubRequestOrBuilder

Enclosing class:

PubSubProtocol.PubSubRequest

public static final class PubSubProtocol.PubSubRequest.Builder
extends com.google.protobuf.GeneratedMessage.Builder<PubSubProtocol.PubSubRequest.Builder>
implements PubSubProtocol.PubSubRequestOrBuilder

Protobuf type Hedwig.PubSubRequest

 A PubSubRequest is just a union of the various request types, with
 an enum telling us which type it is. The same can also be done through 
 extensions. We need one request type that we will deserialize into on 
 the server side.
 

Method Summary

Modifier and Type	Method and Description
PubSubProtocol.PubSubRequest.Builder	addAllTriedServers(Iterable<? extends com.google.protobuf.ByteString> values) repeated bytes triedServers = 3;
PubSubProtocol.PubSubRequest.Builder	addTriedServers(com.google.protobuf.ByteString value) repeated bytes triedServers = 3;
PubSubProtocol.PubSubRequest	build()
PubSubProtocol.PubSubRequest	buildPartial()
PubSubProtocol.PubSubRequest.Builder	clear()
PubSubProtocol.PubSubRequest.Builder	clearCloseSubscriptionRequest() optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.PubSubRequest.Builder	clearConsumeRequest() optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.PubSubRequest.Builder	clearProtocolVersion() required .Hedwig.ProtocolVersion protocolVersion = 1;
PubSubProtocol.PubSubRequest.Builder	clearPublishRequest() optional .Hedwig.PublishRequest publishRequest = 52;
PubSubProtocol.PubSubRequest.Builder	clearShouldClaim() optional bool shouldClaim = 5;
PubSubProtocol.PubSubRequest.Builder	clearStartDeliveryRequest() optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.PubSubRequest.Builder	clearStopDeliveryRequest() optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.PubSubRequest.Builder	clearSubscribeRequest() optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.PubSubRequest.Builder	clearTopic() required bytes topic = 6;
PubSubProtocol.PubSubRequest.Builder	clearTriedServers() repeated bytes triedServers = 3;
PubSubProtocol.PubSubRequest.Builder	clearTxnId() required uint64 txnId = 4;
PubSubProtocol.PubSubRequest.Builder	clearType() required .Hedwig.OperationType type = 2;
PubSubProtocol.PubSubRequest.Builder	clearUnsubscribeRequest() optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
PubSubProtocol.PubSubRequest.Builder	clone()
PubSubProtocol.CloseSubscriptionRequest	getCloseSubscriptionRequest() optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.CloseSubscriptionRequest.Builder	getCloseSubscriptionRequestBuilder() optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.CloseSubscriptionRequestOrBuilder	getCloseSubscriptionRequestOrBuilder() optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.ConsumeRequest	getConsumeRequest() optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.ConsumeRequest.Builder	getConsumeRequestBuilder() optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.ConsumeRequestOrBuilder	getConsumeRequestOrBuilder() optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.PubSubRequest	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
PubSubProtocol.ProtocolVersion	getProtocolVersion() required .Hedwig.ProtocolVersion protocolVersion = 1;
PubSubProtocol.PublishRequest	getPublishRequest() optional .Hedwig.PublishRequest publishRequest = 52;
PubSubProtocol.PublishRequest.Builder	getPublishRequestBuilder() optional .Hedwig.PublishRequest publishRequest = 52;
PubSubProtocol.PublishRequestOrBuilder	getPublishRequestOrBuilder() optional .Hedwig.PublishRequest publishRequest = 52;
boolean	getShouldClaim() optional bool shouldClaim = 5;
PubSubProtocol.StartDeliveryRequest	getStartDeliveryRequest() optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.StartDeliveryRequest.Builder	getStartDeliveryRequestBuilder() optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.StartDeliveryRequestOrBuilder	getStartDeliveryRequestOrBuilder() optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.StopDeliveryRequest	getStopDeliveryRequest() optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.StopDeliveryRequest.Builder	getStopDeliveryRequestBuilder() optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.StopDeliveryRequestOrBuilder	getStopDeliveryRequestOrBuilder() optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.SubscribeRequest	getSubscribeRequest() optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.SubscribeRequest.Builder	getSubscribeRequestBuilder() optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.SubscribeRequestOrBuilder	getSubscribeRequestOrBuilder() optional .Hedwig.SubscribeRequest subscribeRequest = 53;
com.google.protobuf.ByteString	getTopic() required bytes topic = 6;
com.google.protobuf.ByteString	getTriedServers(int index) repeated bytes triedServers = 3;
int	getTriedServersCount() repeated bytes triedServers = 3;
List<com.google.protobuf.ByteString>	getTriedServersList() repeated bytes triedServers = 3;
long	getTxnId() required uint64 txnId = 4;
PubSubProtocol.OperationType	getType() required .Hedwig.OperationType type = 2;
PubSubProtocol.UnsubscribeRequest	getUnsubscribeRequest() optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
PubSubProtocol.UnsubscribeRequest.Builder	getUnsubscribeRequestBuilder() optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
PubSubProtocol.UnsubscribeRequestOrBuilder	getUnsubscribeRequestOrBuilder() optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
boolean	hasCloseSubscriptionRequest() optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
boolean	hasConsumeRequest() optional .Hedwig.ConsumeRequest consumeRequest = 54;
boolean	hasProtocolVersion() required .Hedwig.ProtocolVersion protocolVersion = 1;
boolean	hasPublishRequest() optional .Hedwig.PublishRequest publishRequest = 52;
boolean	hasShouldClaim() optional bool shouldClaim = 5;
boolean	hasStartDeliveryRequest() optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
boolean	hasStopDeliveryRequest() optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
boolean	hasSubscribeRequest() optional .Hedwig.SubscribeRequest subscribeRequest = 53;
boolean	hasTopic() required bytes topic = 6;
boolean	hasTxnId() required uint64 txnId = 4;
boolean	hasType() required .Hedwig.OperationType type = 2;
boolean	hasUnsubscribeRequest() optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
PubSubProtocol.PubSubRequest.Builder	mergeCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value) optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.PubSubRequest.Builder	mergeConsumeRequest(PubSubProtocol.ConsumeRequest value) optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.PubSubRequest.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
PubSubProtocol.PubSubRequest.Builder	mergeFrom(com.google.protobuf.Message other)
PubSubProtocol.PubSubRequest.Builder	mergeFrom(PubSubProtocol.PubSubRequest other)
PubSubProtocol.PubSubRequest.Builder	mergePublishRequest(PubSubProtocol.PublishRequest value) optional .Hedwig.PublishRequest publishRequest = 52;
PubSubProtocol.PubSubRequest.Builder	mergeStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value) optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.PubSubRequest.Builder	mergeStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value) optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.PubSubRequest.Builder	mergeSubscribeRequest(PubSubProtocol.SubscribeRequest value) optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.PubSubRequest.Builder	mergeUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value) optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
PubSubProtocol.PubSubRequest.Builder	setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest.Builder builderForValue) optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.PubSubRequest.Builder	setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value) optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.PubSubRequest.Builder	setConsumeRequest(PubSubProtocol.ConsumeRequest.Builder builderForValue) optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.PubSubRequest.Builder	setConsumeRequest(PubSubProtocol.ConsumeRequest value) optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.PubSubRequest.Builder	setProtocolVersion(PubSubProtocol.ProtocolVersion value) required .Hedwig.ProtocolVersion protocolVersion = 1;
PubSubProtocol.PubSubRequest.Builder	setPublishRequest(PubSubProtocol.PublishRequest.Builder builderForValue) optional .Hedwig.PublishRequest publishRequest = 52;
PubSubProtocol.PubSubRequest.Builder	setPublishRequest(PubSubProtocol.PublishRequest value) optional .Hedwig.PublishRequest publishRequest = 52;
PubSubProtocol.PubSubRequest.Builder	setShouldClaim(boolean value) optional bool shouldClaim = 5;
PubSubProtocol.PubSubRequest.Builder	setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest.Builder builderForValue) optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.PubSubRequest.Builder	setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value) optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.PubSubRequest.Builder	setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest.Builder builderForValue) optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.PubSubRequest.Builder	setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value) optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.PubSubRequest.Builder	setSubscribeRequest(PubSubProtocol.SubscribeRequest.Builder builderForValue) optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.PubSubRequest.Builder	setSubscribeRequest(PubSubProtocol.SubscribeRequest value) optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.PubSubRequest.Builder	setTopic(com.google.protobuf.ByteString value) required bytes topic = 6;
PubSubProtocol.PubSubRequest.Builder	setTriedServers(int index, com.google.protobuf.ByteString value) repeated bytes triedServers = 3;
PubSubProtocol.PubSubRequest.Builder	setTxnId(long value) required uint64 txnId = 4;
PubSubProtocol.PubSubRequest.Builder	setType(PubSubProtocol.OperationType value) required .Hedwig.OperationType type = 2;
PubSubProtocol.PubSubRequest.Builder	setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest.Builder builderForValue) optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
PubSubProtocol.PubSubRequest.Builder	setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value) optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, getAllFields, getField, getFieldBuilder, getParentForChildren, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, isClean, markClean, mergeUnknownFields, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFields

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

addAll, newUninitializedMessageException

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField

Method Detail

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.Builder<PubSubProtocol.PubSubRequest.Builder>

clear

public PubSubProtocol.PubSubRequest.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<PubSubProtocol.PubSubRequest.Builder>

clone

public PubSubProtocol.PubSubRequest.Builder clone()

Specified by:

clone in interface com.google.protobuf.Message.Builder

Specified by:

clone in interface com.google.protobuf.MessageLite.Builder

Overrides:

clone in class com.google.protobuf.GeneratedMessage.Builder<PubSubProtocol.PubSubRequest.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<PubSubProtocol.PubSubRequest.Builder>

getDefaultInstanceForType

public PubSubProtocol.PubSubRequest getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public PubSubProtocol.PubSubRequest build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public PubSubProtocol.PubSubRequest buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public PubSubProtocol.PubSubRequest.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<PubSubProtocol.PubSubRequest.Builder>

mergeFrom

public PubSubProtocol.PubSubRequest.Builder mergeFrom(PubSubProtocol.PubSubRequest other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<PubSubProtocol.PubSubRequest.Builder>

mergeFrom

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

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<PubSubProtocol.PubSubRequest.Builder>

Throws:

IOException

hasProtocolVersion

public boolean hasProtocolVersion()

required .Hedwig.ProtocolVersion protocolVersion = 1;

Specified by:

hasProtocolVersion in interface PubSubProtocol.PubSubRequestOrBuilder

getProtocolVersion

public PubSubProtocol.ProtocolVersion getProtocolVersion()

required .Hedwig.ProtocolVersion protocolVersion = 1;

Specified by:

getProtocolVersion in interface PubSubProtocol.PubSubRequestOrBuilder

setProtocolVersion

public PubSubProtocol.PubSubRequest.Builder setProtocolVersion(PubSubProtocol.ProtocolVersion value)

required .Hedwig.ProtocolVersion protocolVersion = 1;

clearProtocolVersion

public PubSubProtocol.PubSubRequest.Builder clearProtocolVersion()

required .Hedwig.ProtocolVersion protocolVersion = 1;

hasType

public boolean hasType()

required .Hedwig.OperationType type = 2;

Specified by:

hasType in interface PubSubProtocol.PubSubRequestOrBuilder

getType

public PubSubProtocol.OperationType getType()

required .Hedwig.OperationType type = 2;

Specified by:

getType in interface PubSubProtocol.PubSubRequestOrBuilder

setType

public PubSubProtocol.PubSubRequest.Builder setType(PubSubProtocol.OperationType value)

required .Hedwig.OperationType type = 2;

clearType

public PubSubProtocol.PubSubRequest.Builder clearType()

required .Hedwig.OperationType type = 2;

getTriedServersList

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

repeated bytes triedServers = 3;

Specified by:

getTriedServersList in interface PubSubProtocol.PubSubRequestOrBuilder

getTriedServersCount

public int getTriedServersCount()

repeated bytes triedServers = 3;

Specified by:

getTriedServersCount in interface PubSubProtocol.PubSubRequestOrBuilder

getTriedServers

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

repeated bytes triedServers = 3;

Specified by:

getTriedServers in interface PubSubProtocol.PubSubRequestOrBuilder

setTriedServers

public PubSubProtocol.PubSubRequest.Builder setTriedServers(int index,
                                                            com.google.protobuf.ByteString value)

repeated bytes triedServers = 3;

addTriedServers

public PubSubProtocol.PubSubRequest.Builder addTriedServers(com.google.protobuf.ByteString value)

repeated bytes triedServers = 3;

addAllTriedServers

public PubSubProtocol.PubSubRequest.Builder addAllTriedServers(Iterable<? extends com.google.protobuf.ByteString> values)

repeated bytes triedServers = 3;

clearTriedServers

public PubSubProtocol.PubSubRequest.Builder clearTriedServers()

repeated bytes triedServers = 3;

hasTxnId

public boolean hasTxnId()

required uint64 txnId = 4;

Specified by:

hasTxnId in interface PubSubProtocol.PubSubRequestOrBuilder

getTxnId

public long getTxnId()

required uint64 txnId = 4;

Specified by:

getTxnId in interface PubSubProtocol.PubSubRequestOrBuilder

setTxnId

public PubSubProtocol.PubSubRequest.Builder setTxnId(long value)

required uint64 txnId = 4;

clearTxnId

public PubSubProtocol.PubSubRequest.Builder clearTxnId()

required uint64 txnId = 4;

hasShouldClaim

public boolean hasShouldClaim()

optional bool shouldClaim = 5;

Specified by:

hasShouldClaim in interface PubSubProtocol.PubSubRequestOrBuilder

getShouldClaim

public boolean getShouldClaim()

optional bool shouldClaim = 5;

Specified by:

getShouldClaim in interface PubSubProtocol.PubSubRequestOrBuilder

setShouldClaim

public PubSubProtocol.PubSubRequest.Builder setShouldClaim(boolean value)

optional bool shouldClaim = 5;

clearShouldClaim

public PubSubProtocol.PubSubRequest.Builder clearShouldClaim()

optional bool shouldClaim = 5;

hasTopic

public boolean hasTopic()

required bytes topic = 6;

any authentication stuff and other general stuff here
 

Specified by:

hasTopic in interface PubSubProtocol.PubSubRequestOrBuilder

getTopic

public com.google.protobuf.ByteString getTopic()

required bytes topic = 6;

any authentication stuff and other general stuff here
 

Specified by:

getTopic in interface PubSubProtocol.PubSubRequestOrBuilder

setTopic

public PubSubProtocol.PubSubRequest.Builder setTopic(com.google.protobuf.ByteString value)

required bytes topic = 6;

any authentication stuff and other general stuff here
 

clearTopic

public PubSubProtocol.PubSubRequest.Builder clearTopic()

required bytes topic = 6;

any authentication stuff and other general stuff here
 

hasPublishRequest

public boolean hasPublishRequest()

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

Specified by:

hasPublishRequest in interface PubSubProtocol.PubSubRequestOrBuilder

getPublishRequest

public PubSubProtocol.PublishRequest getPublishRequest()

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

Specified by:

getPublishRequest in interface PubSubProtocol.PubSubRequestOrBuilder

setPublishRequest

public PubSubProtocol.PubSubRequest.Builder setPublishRequest(PubSubProtocol.PublishRequest value)

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

setPublishRequest

public PubSubProtocol.PubSubRequest.Builder setPublishRequest(PubSubProtocol.PublishRequest.Builder builderForValue)

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

mergePublishRequest

public PubSubProtocol.PubSubRequest.Builder mergePublishRequest(PubSubProtocol.PublishRequest value)

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

clearPublishRequest

public PubSubProtocol.PubSubRequest.Builder clearPublishRequest()

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

getPublishRequestBuilder

public PubSubProtocol.PublishRequest.Builder getPublishRequestBuilder()

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

getPublishRequestOrBuilder

public PubSubProtocol.PublishRequestOrBuilder getPublishRequestOrBuilder()

optional .Hedwig.PublishRequest publishRequest = 52;

 one entry for each type of request 
 

Specified by:

getPublishRequestOrBuilder in interface PubSubProtocol.PubSubRequestOrBuilder

hasSubscribeRequest

public boolean hasSubscribeRequest()

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

Specified by:

hasSubscribeRequest in interface PubSubProtocol.PubSubRequestOrBuilder

getSubscribeRequest

public PubSubProtocol.SubscribeRequest getSubscribeRequest()

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

Specified by:

getSubscribeRequest in interface PubSubProtocol.PubSubRequestOrBuilder

setSubscribeRequest

public PubSubProtocol.PubSubRequest.Builder setSubscribeRequest(PubSubProtocol.SubscribeRequest value)

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

setSubscribeRequest

public PubSubProtocol.PubSubRequest.Builder setSubscribeRequest(PubSubProtocol.SubscribeRequest.Builder builderForValue)

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

mergeSubscribeRequest

public PubSubProtocol.PubSubRequest.Builder mergeSubscribeRequest(PubSubProtocol.SubscribeRequest value)

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

clearSubscribeRequest

public PubSubProtocol.PubSubRequest.Builder clearSubscribeRequest()

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

getSubscribeRequestBuilder

public PubSubProtocol.SubscribeRequest.Builder getSubscribeRequestBuilder()

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

getSubscribeRequestOrBuilder

public PubSubProtocol.SubscribeRequestOrBuilder getSubscribeRequestOrBuilder()

optional .Hedwig.SubscribeRequest subscribeRequest = 53;

Specified by:

getSubscribeRequestOrBuilder in interface PubSubProtocol.PubSubRequestOrBuilder

hasConsumeRequest

public boolean hasConsumeRequest()

optional .Hedwig.ConsumeRequest consumeRequest = 54;

Specified by:

hasConsumeRequest in interface PubSubProtocol.PubSubRequestOrBuilder

getConsumeRequest

public PubSubProtocol.ConsumeRequest getConsumeRequest()

optional .Hedwig.ConsumeRequest consumeRequest = 54;

Specified by:

getConsumeRequest in interface PubSubProtocol.PubSubRequestOrBuilder

setConsumeRequest

public PubSubProtocol.PubSubRequest.Builder setConsumeRequest(PubSubProtocol.ConsumeRequest value)

optional .Hedwig.ConsumeRequest consumeRequest = 54;

setConsumeRequest

public PubSubProtocol.PubSubRequest.Builder setConsumeRequest(PubSubProtocol.ConsumeRequest.Builder builderForValue)

optional .Hedwig.ConsumeRequest consumeRequest = 54;

mergeConsumeRequest

public PubSubProtocol.PubSubRequest.Builder mergeConsumeRequest(PubSubProtocol.ConsumeRequest value)

optional .Hedwig.ConsumeRequest consumeRequest = 54;

clearConsumeRequest

public PubSubProtocol.PubSubRequest.Builder clearConsumeRequest()

optional .Hedwig.ConsumeRequest consumeRequest = 54;

getConsumeRequestBuilder

public PubSubProtocol.ConsumeRequest.Builder getConsumeRequestBuilder()

optional .Hedwig.ConsumeRequest consumeRequest = 54;

getConsumeRequestOrBuilder

public PubSubProtocol.ConsumeRequestOrBuilder getConsumeRequestOrBuilder()

optional .Hedwig.ConsumeRequest consumeRequest = 54;

Specified by:

getConsumeRequestOrBuilder in interface PubSubProtocol.PubSubRequestOrBuilder

hasUnsubscribeRequest

public boolean hasUnsubscribeRequest()

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

Specified by:

hasUnsubscribeRequest in interface PubSubProtocol.PubSubRequestOrBuilder

getUnsubscribeRequest

public PubSubProtocol.UnsubscribeRequest getUnsubscribeRequest()

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

Specified by:

getUnsubscribeRequest in interface PubSubProtocol.PubSubRequestOrBuilder

setUnsubscribeRequest

public PubSubProtocol.PubSubRequest.Builder setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value)

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

setUnsubscribeRequest

public PubSubProtocol.PubSubRequest.Builder setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest.Builder builderForValue)

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

mergeUnsubscribeRequest

public PubSubProtocol.PubSubRequest.Builder mergeUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value)

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

clearUnsubscribeRequest

public PubSubProtocol.PubSubRequest.Builder clearUnsubscribeRequest()

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

getUnsubscribeRequestBuilder

public PubSubProtocol.UnsubscribeRequest.Builder getUnsubscribeRequestBuilder()

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

getUnsubscribeRequestOrBuilder

public PubSubProtocol.UnsubscribeRequestOrBuilder getUnsubscribeRequestOrBuilder()

optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;

Specified by:

getUnsubscribeRequestOrBuilder in interface PubSubProtocol.PubSubRequestOrBuilder

hasStopDeliveryRequest

public boolean hasStopDeliveryRequest()

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

Specified by:

hasStopDeliveryRequest in interface PubSubProtocol.PubSubRequestOrBuilder

getStopDeliveryRequest

public PubSubProtocol.StopDeliveryRequest getStopDeliveryRequest()

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

Specified by:

getStopDeliveryRequest in interface PubSubProtocol.PubSubRequestOrBuilder

setStopDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value)

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

setStopDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest.Builder builderForValue)

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

mergeStopDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder mergeStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value)

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

clearStopDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder clearStopDeliveryRequest()

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

getStopDeliveryRequestBuilder

public PubSubProtocol.StopDeliveryRequest.Builder getStopDeliveryRequestBuilder()

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

getStopDeliveryRequestOrBuilder

public PubSubProtocol.StopDeliveryRequestOrBuilder getStopDeliveryRequestOrBuilder()

optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;

Specified by:

getStopDeliveryRequestOrBuilder in interface PubSubProtocol.PubSubRequestOrBuilder

hasStartDeliveryRequest

public boolean hasStartDeliveryRequest()

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

Specified by:

hasStartDeliveryRequest in interface PubSubProtocol.PubSubRequestOrBuilder

getStartDeliveryRequest

public PubSubProtocol.StartDeliveryRequest getStartDeliveryRequest()

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

Specified by:

getStartDeliveryRequest in interface PubSubProtocol.PubSubRequestOrBuilder

setStartDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value)

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

setStartDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest.Builder builderForValue)

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

mergeStartDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder mergeStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value)

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

clearStartDeliveryRequest

public PubSubProtocol.PubSubRequest.Builder clearStartDeliveryRequest()

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

getStartDeliveryRequestBuilder

public PubSubProtocol.StartDeliveryRequest.Builder getStartDeliveryRequestBuilder()

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

getStartDeliveryRequestOrBuilder

public PubSubProtocol.StartDeliveryRequestOrBuilder getStartDeliveryRequestOrBuilder()

optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;

Specified by:

getStartDeliveryRequestOrBuilder in interface PubSubProtocol.PubSubRequestOrBuilder

hasCloseSubscriptionRequest

public boolean hasCloseSubscriptionRequest()

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

Specified by:

hasCloseSubscriptionRequest in interface PubSubProtocol.PubSubRequestOrBuilder

getCloseSubscriptionRequest

public PubSubProtocol.CloseSubscriptionRequest getCloseSubscriptionRequest()

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

Specified by:

getCloseSubscriptionRequest in interface PubSubProtocol.PubSubRequestOrBuilder

setCloseSubscriptionRequest

public PubSubProtocol.PubSubRequest.Builder setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value)

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

setCloseSubscriptionRequest

public PubSubProtocol.PubSubRequest.Builder setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest.Builder builderForValue)

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

mergeCloseSubscriptionRequest

public PubSubProtocol.PubSubRequest.Builder mergeCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value)

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

clearCloseSubscriptionRequest

public PubSubProtocol.PubSubRequest.Builder clearCloseSubscriptionRequest()

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

getCloseSubscriptionRequestBuilder

public PubSubProtocol.CloseSubscriptionRequest.Builder getCloseSubscriptionRequestBuilder()

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

getCloseSubscriptionRequestOrBuilder

public PubSubProtocol.CloseSubscriptionRequestOrBuilder getCloseSubscriptionRequestOrBuilder()

optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;

Specified by:

getCloseSubscriptionRequestOrBuilder in interface PubSubProtocol.PubSubRequestOrBuilder