public class GetDurableCQs extends BaseCQCommand
| Modifier and Type | Method and Description |
|---|---|
void |
cmdExecute(org.apache.geode.internal.cache.tier.sockets.Message clientMessage,
org.apache.geode.internal.cache.tier.sockets.ServerConnection serverConnection,
long start) |
static org.apache.geode.internal.cache.tier.Command |
getCommand() |
getCollectionType, processQuery, processQueryUsingParams, sendCqResponseappendNewRegisterInterestResponseChunk, appendNewRegisterInterestResponseChunkFromLocal, checkForInterrupt, execute, fillAndSendRegisterInterestResponseChunks, fillAndSendRegisterInterestResponseChunks, findVersionTagsForRetriedBulkOp, getExceptionTrace, okBytes, recoverVersionTagForRetriedOperation, sendNewRegisterInterestResponseChunk, shouldMasqueradeForTx, writeChunkedErrorResponse, writeChunkedException, writeChunkedException, writeErrorResponse, writeErrorResponse, writeException, writeException, writeFunctionResponseError, writeFunctionResponseException, writeKeySetErrorResponse, writeQueryResponseException, writeRegionDestroyedEx, writeReply, writeReplyWithRefreshMetadata, writeResponse, writeResponseWithFunctionAttribute, writeResponseWithRefreshMetadatapublic static org.apache.geode.internal.cache.tier.Command getCommand()
public void cmdExecute(org.apache.geode.internal.cache.tier.sockets.Message clientMessage,
org.apache.geode.internal.cache.tier.sockets.ServerConnection serverConnection,
long start)
throws java.io.IOException,
java.lang.InterruptedException
cmdExecute in class org.apache.geode.internal.cache.tier.sockets.BaseCommandjava.io.IOExceptionjava.lang.InterruptedException