org.apache.geode.cache.client.internal

Class CreateCQOp.CreateCQOpImpl

java.lang.Object

org.apache.geode.cache.client.internal.AbstractOp

org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

All Implemented Interfaces:

org.apache.geode.cache.client.internal.Op

Enclosing class:

CreateCQOp

protected static class CreateCQOp.CreateCQOpImpl
extends org.apache.geode.cache.client.internal.AbstractOp

Note both StopCQOpImpl and CloseCQOpImpl extend this class

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.geode.cache.client.internal.AbstractOp

org.apache.geode.cache.client.internal.AbstractOp.ChunkHandler

Field Summary

Fields inherited from class org.apache.geode.cache.client.internal.AbstractOp

failed, timedOut

Constructor Summary

Constructors

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)

Method Summary

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)

Methods inherited from class org.apache.geode.cache.client.internal.AbstractOp

attempt, attemptReadResponse, attemptSend, getMessage, getShortClassName, hasFailed, hasTimedOut, initMessagePart, isAllowDuplicateMetadataRefresh, isGatewaySenderOp, needsUserId, participateInTransaction, processAck, processChunkedResponse, processObjResponse, processResponse, processSecureBytes, sendMessage, setAllowDuplicateMetadataRefresh, useThreadLocalConnection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreateCQOpImpl

public CreateCQOpImpl(java.lang.String cqName,
                      java.lang.String queryStr,
                      int cqState,
                      boolean isDurable,
                      byte regionDataPolicy)

Throws:

org.apache.geode.SerializationException - if serialization fails

CreateCQOpImpl

protected CreateCQOpImpl(int msgType,
                         int numParts)

This constructor is for our subclasses

Throws:

org.apache.geode.SerializationException - if serialization fails

Method Detail

createResponseMessage

protected org.apache.geode.internal.cache.tier.sockets.Message createResponseMessage()

Overrides:

createResponseMessage in class org.apache.geode.cache.client.internal.AbstractOp

processResponse

protected java.lang.Object processResponse(org.apache.geode.internal.cache.tier.sockets.Message m)
                                    throws java.lang.Exception

Specified by:

processResponse in class org.apache.geode.cache.client.internal.AbstractOp

Throws:

java.lang.Exception

getOpName

protected java.lang.String getOpName()

isErrorResponse

protected boolean isErrorResponse(int msgType)

Specified by:

isErrorResponse in class org.apache.geode.cache.client.internal.AbstractOp

startAttempt

protected long startAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats)

Specified by:

startAttempt in class org.apache.geode.cache.client.internal.AbstractOp

endSendAttempt

protected void endSendAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats,
                              long start)

Specified by:

endSendAttempt in class org.apache.geode.cache.client.internal.AbstractOp

endAttempt

protected void endAttempt(org.apache.geode.cache.client.internal.ConnectionStats stats,
                          long start)

Specified by:

endAttempt in class org.apache.geode.cache.client.internal.AbstractOp