public class PubSubData extends Object
Modifier and Type | Field and Description |
---|---|
protected static String |
COMMA |
List<com.google.protobuf.ByteString> |
connectFailedServers |
Object |
context |
boolean |
isDone |
PubSubProtocol.Message |
msg |
PubSubProtocol.OperationType |
operationType |
PubSubProtocol.SubscriptionOptions |
options |
long |
requestWriteTime |
boolean |
shouldClaim |
com.google.protobuf.ByteString |
subscriberId |
com.google.protobuf.ByteString |
topic |
List<com.google.protobuf.ByteString> |
triedServers |
long |
txnId |
List<com.google.protobuf.ByteString> |
writeFailedServers |
Constructor and Description |
---|
PubSubData(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.OperationType operationType,
PubSubProtocol.SubscriptionOptions options,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
Modifier and Type | Method and Description |
---|---|
void |
clearServersList() |
Callback<PubSubProtocol.ResponseBody> |
getCallback() |
HChannel |
getOriginalChannelForResubscribe() |
boolean |
isResubscribeRequest() |
void |
operationFinishedToCallback(Object context,
PubSubProtocol.ResponseBody response) |
void |
setCallback(Callback<PubSubProtocol.ResponseBody> callback) |
void |
setOriginalChannelForResubscribe(HChannel channel) |
String |
toString() |
protected static final String COMMA
public final com.google.protobuf.ByteString topic
public final PubSubProtocol.Message msg
public final com.google.protobuf.ByteString subscriberId
public final PubSubProtocol.OperationType operationType
public final PubSubProtocol.SubscriptionOptions options
public Object context
public List<com.google.protobuf.ByteString> triedServers
public List<com.google.protobuf.ByteString> connectFailedServers
public List<com.google.protobuf.ByteString> writeFailedServers
public boolean shouldClaim
public long txnId
public long requestWriteTime
public boolean isDone
public PubSubData(com.google.protobuf.ByteString topic, PubSubProtocol.Message msg, com.google.protobuf.ByteString subscriberId, PubSubProtocol.OperationType operationType, PubSubProtocol.SubscriptionOptions options, Callback<PubSubProtocol.ResponseBody> callback, Object context)
public void setCallback(Callback<PubSubProtocol.ResponseBody> callback)
public Callback<PubSubProtocol.ResponseBody> getCallback()
public void operationFinishedToCallback(Object context, PubSubProtocol.ResponseBody response)
public boolean isResubscribeRequest()
public HChannel getOriginalChannelForResubscribe()
public void setOriginalChannelForResubscribe(HChannel channel)
public void clearServersList()
Copyright © 2011–2016 The Apache Software Foundation. All rights reserved.