public static interface PubSubProtocol.SubscriptionOptionsOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.SubscribeRequest.CreateOrAttach |
getCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH]; |
boolean |
getEnableResubscribe()
optional bool enableResubscribe = 7 [default = true]; |
boolean |
getForceAttach()
optional bool forceAttach = 1 [default = false]; |
int |
getMessageBound()
optional uint32 messageBound = 3 [default = 0]; |
String |
getMessageFilter()
optional string messageFilter = 5; |
com.google.protobuf.ByteString |
getMessageFilterBytes()
optional string messageFilter = 5; |
int |
getMessageWindowSize()
optional uint32 messageWindowSize = 6; |
PubSubProtocol.Map |
getOptions()
optional .Hedwig.Map options = 4; |
PubSubProtocol.MapOrBuilder |
getOptionsOrBuilder()
optional .Hedwig.Map options = 4; |
boolean |
hasCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH]; |
boolean |
hasEnableResubscribe()
optional bool enableResubscribe = 7 [default = true]; |
boolean |
hasForceAttach()
optional bool forceAttach = 1 [default = false]; |
boolean |
hasMessageBound()
optional uint32 messageBound = 3 [default = 0]; |
boolean |
hasMessageFilter()
optional string messageFilter = 5; |
boolean |
hasMessageWindowSize()
optional uint32 messageWindowSize = 6; |
boolean |
hasOptions()
optional .Hedwig.Map options = 4; |
boolean hasForceAttach()
optional bool forceAttach = 1 [default = false];
force attach subscription which would kill existed channel this option doesn't need to be persisted
boolean getForceAttach()
optional bool forceAttach = 1 [default = false];
force attach subscription which would kill existed channel this option doesn't need to be persisted
boolean hasCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
PubSubProtocol.SubscribeRequest.CreateOrAttach getCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
boolean hasMessageBound()
optional uint32 messageBound = 3 [default = 0];
int getMessageBound()
optional uint32 messageBound = 3 [default = 0];
boolean hasOptions()
optional .Hedwig.Map options = 4;
user customized subscription options
PubSubProtocol.Map getOptions()
optional .Hedwig.Map options = 4;
user customized subscription options
PubSubProtocol.MapOrBuilder getOptionsOrBuilder()
optional .Hedwig.Map options = 4;
user customized subscription options
boolean hasMessageFilter()
optional string messageFilter = 5;
server-side message filter
String getMessageFilter()
optional string messageFilter = 5;
server-side message filter
com.google.protobuf.ByteString getMessageFilterBytes()
optional string messageFilter = 5;
server-side message filter
boolean hasMessageWindowSize()
optional uint32 messageWindowSize = 6;
message window size, this is the maximum number of messages which will be delivered without being consumed
int getMessageWindowSize()
optional uint32 messageWindowSize = 6;
message window size, this is the maximum number of messages which will be delivered without being consumed
boolean hasEnableResubscribe()
optional bool enableResubscribe = 7 [default = true];
enable resubscribe
boolean getEnableResubscribe()
optional bool enableResubscribe = 7 [default = true];
enable resubscribe
Copyright © 2013 The Apache Software Foundation. All rights reserved.