PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.addAllTriedServers(Iterable<? extends com.google.protobuf.ByteString> values)
repeated bytes triedServers = 3;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.addTriedServers(com.google.protobuf.ByteString value)
repeated bytes triedServers = 3;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clear() |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearCloseSubscriptionRequest()
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearConsumeRequest()
optional .Hedwig.ConsumeRequest consumeRequest = 54;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearProtocolVersion()
required .Hedwig.ProtocolVersion protocolVersion = 1;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearPublishRequest()
optional .Hedwig.PublishRequest publishRequest = 52;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearShouldClaim()
optional bool shouldClaim = 5;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearStartDeliveryRequest()
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearStopDeliveryRequest()
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearSubscribeRequest()
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearTopic()
required bytes topic = 6;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearTriedServers()
repeated bytes triedServers = 3;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearTxnId()
required uint64 txnId = 4;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearType()
required .Hedwig.OperationType type = 2;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearUnsubscribeRequest()
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clone() |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value)
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeConsumeRequest(PubSubProtocol.ConsumeRequest value)
optional .Hedwig.ConsumeRequest consumeRequest = 54;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeFrom(com.google.protobuf.Message other) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeFrom(PubSubProtocol.PubSubRequest other) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergePublishRequest(PubSubProtocol.PublishRequest value)
optional .Hedwig.PublishRequest publishRequest = 52;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value)
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value)
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeSubscribeRequest(PubSubProtocol.SubscribeRequest value)
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value)
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
|
static PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilder() |
static PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilder(PubSubProtocol.PubSubRequest prototype) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilderForType() |
protected PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest.Builder builderForValue)
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value)
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setConsumeRequest(PubSubProtocol.ConsumeRequest.Builder builderForValue)
optional .Hedwig.ConsumeRequest consumeRequest = 54;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setConsumeRequest(PubSubProtocol.ConsumeRequest value)
optional .Hedwig.ConsumeRequest consumeRequest = 54;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setProtocolVersion(PubSubProtocol.ProtocolVersion value)
required .Hedwig.ProtocolVersion protocolVersion = 1;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setPublishRequest(PubSubProtocol.PublishRequest.Builder builderForValue)
optional .Hedwig.PublishRequest publishRequest = 52;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setPublishRequest(PubSubProtocol.PublishRequest value)
optional .Hedwig.PublishRequest publishRequest = 52;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setShouldClaim(boolean value)
optional bool shouldClaim = 5;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest.Builder builderForValue)
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value)
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest.Builder builderForValue)
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value)
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setSubscribeRequest(PubSubProtocol.SubscribeRequest.Builder builderForValue)
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setSubscribeRequest(PubSubProtocol.SubscribeRequest value)
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setTopic(com.google.protobuf.ByteString value)
required bytes topic = 6;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setTriedServers(int index,
com.google.protobuf.ByteString value)
repeated bytes triedServers = 3;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setTxnId(long value)
required uint64 txnId = 4;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setType(PubSubProtocol.OperationType value)
required .Hedwig.OperationType type = 2;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest.Builder builderForValue)
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value)
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.toBuilder() |