protected static class CreateCQOp.CreateCQOpImpl
extends org.apache.geode.cache.client.internal.AbstractOp
| Modifier | Constructor and Description |
|---|---|
protected |
CreateCQOpImpl(int msgType,
int numParts)
This constructor is for our subclasses
|
|
CreateCQOpImpl(java.lang.String cqName,
java.lang.String queryStr,
int cqState,
boolean isDurable,
byte regionDataPolicy) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.geode.internal.cache.tier.sockets.Message |
createResponseMessage() |
protected void |
endAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats,
long start) |
protected void |
endSendAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats,
long start) |
protected java.lang.String |
getOpName() |
protected boolean |
isErrorResponse(int msgType) |
protected java.lang.Object |
processResponse(org.apache.geode.internal.cache.tier.sockets.Message m) |
protected long |
startAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats) |
attempt, attemptReadResponse, attemptSend, getMessage, getShortClassName, hasFailed, hasTimedOut, initMessagePart, isAllowDuplicateMetadataRefresh, isGatewaySenderOp, needsUserId, participateInTransaction, processAck, processChunkedResponse, processObjResponse, processResponse, processSecureBytes, sendMessage, setAllowDuplicateMetadataRefresh, useThreadLocalConnectionpublic CreateCQOpImpl(java.lang.String cqName,
java.lang.String queryStr,
int cqState,
boolean isDurable,
byte regionDataPolicy)
org.apache.geode.SerializationException - if serialization failsprotected CreateCQOpImpl(int msgType,
int numParts)
org.apache.geode.SerializationException - if serialization failsprotected org.apache.geode.internal.cache.tier.sockets.Message createResponseMessage()
createResponseMessage in class org.apache.geode.cache.client.internal.AbstractOpprotected java.lang.Object processResponse(org.apache.geode.internal.cache.tier.sockets.Message m)
throws java.lang.Exception
processResponse in class org.apache.geode.cache.client.internal.AbstractOpjava.lang.Exceptionprotected java.lang.String getOpName()
protected boolean isErrorResponse(int msgType)
isErrorResponse in class org.apache.geode.cache.client.internal.AbstractOpprotected long startAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats)
startAttempt in class org.apache.geode.cache.client.internal.AbstractOpprotected void endSendAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats,
long start)
endSendAttempt in class org.apache.geode.cache.client.internal.AbstractOpprotected void endAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats,
long start)
endAttempt in class org.apache.geode.cache.client.internal.AbstractOp