public static interface PubSubProtocol.PubSubRequestOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.CloseSubscriptionRequest |
getCloseSubscriptionRequest()
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58; |
PubSubProtocol.CloseSubscriptionRequestOrBuilder |
getCloseSubscriptionRequestOrBuilder()
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58; |
PubSubProtocol.ConsumeRequest |
getConsumeRequest()
optional .Hedwig.ConsumeRequest consumeRequest = 54; |
PubSubProtocol.ConsumeRequestOrBuilder |
getConsumeRequestOrBuilder()
optional .Hedwig.ConsumeRequest consumeRequest = 54; |
PubSubProtocol.ProtocolVersion |
getProtocolVersion()
required .Hedwig.ProtocolVersion protocolVersion = 1; |
PubSubProtocol.PublishRequest |
getPublishRequest()
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.StartDeliveryRequestOrBuilder |
getStartDeliveryRequestOrBuilder()
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57; |
PubSubProtocol.StopDeliveryRequest |
getStopDeliveryRequest()
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56; |
PubSubProtocol.StopDeliveryRequestOrBuilder |
getStopDeliveryRequestOrBuilder()
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56; |
PubSubProtocol.SubscribeRequest |
getSubscribeRequest()
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.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; |
boolean hasProtocolVersion()
required .Hedwig.ProtocolVersion protocolVersion = 1;
PubSubProtocol.ProtocolVersion getProtocolVersion()
required .Hedwig.ProtocolVersion protocolVersion = 1;
boolean hasType()
required .Hedwig.OperationType type = 2;
PubSubProtocol.OperationType getType()
required .Hedwig.OperationType type = 2;
List<com.google.protobuf.ByteString> getTriedServersList()
repeated bytes triedServers = 3;
int getTriedServersCount()
repeated bytes triedServers = 3;
com.google.protobuf.ByteString getTriedServers(int index)
repeated bytes triedServers = 3;
boolean hasTxnId()
required uint64 txnId = 4;
long getTxnId()
required uint64 txnId = 4;
boolean hasShouldClaim()
optional bool shouldClaim = 5;
boolean getShouldClaim()
optional bool shouldClaim = 5;
boolean hasTopic()
required bytes topic = 6;
any authentication stuff and other general stuff here
com.google.protobuf.ByteString getTopic()
required bytes topic = 6;
any authentication stuff and other general stuff here
boolean hasPublishRequest()
optional .Hedwig.PublishRequest publishRequest = 52;
one entry for each type of request
PubSubProtocol.PublishRequest getPublishRequest()
optional .Hedwig.PublishRequest publishRequest = 52;
one entry for each type of request
PubSubProtocol.PublishRequestOrBuilder getPublishRequestOrBuilder()
optional .Hedwig.PublishRequest publishRequest = 52;
one entry for each type of request
boolean hasSubscribeRequest()
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.SubscribeRequest getSubscribeRequest()
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
PubSubProtocol.SubscribeRequestOrBuilder getSubscribeRequestOrBuilder()
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
boolean hasConsumeRequest()
optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.ConsumeRequest getConsumeRequest()
optional .Hedwig.ConsumeRequest consumeRequest = 54;
PubSubProtocol.ConsumeRequestOrBuilder getConsumeRequestOrBuilder()
optional .Hedwig.ConsumeRequest consumeRequest = 54;
boolean hasUnsubscribeRequest()
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
PubSubProtocol.UnsubscribeRequest getUnsubscribeRequest()
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
PubSubProtocol.UnsubscribeRequestOrBuilder getUnsubscribeRequestOrBuilder()
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
boolean hasStopDeliveryRequest()
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.StopDeliveryRequest getStopDeliveryRequest()
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
PubSubProtocol.StopDeliveryRequestOrBuilder getStopDeliveryRequestOrBuilder()
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
boolean hasStartDeliveryRequest()
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.StartDeliveryRequest getStartDeliveryRequest()
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
PubSubProtocol.StartDeliveryRequestOrBuilder getStartDeliveryRequestOrBuilder()
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
boolean hasCloseSubscriptionRequest()
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.CloseSubscriptionRequest getCloseSubscriptionRequest()
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
PubSubProtocol.CloseSubscriptionRequestOrBuilder getCloseSubscriptionRequestOrBuilder()
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
Copyright © 2013 The Apache Software Foundation. All rights reserved.