com.hazelcast.concurrent.semaphore.operations
public abstract class SemaphoreOperation extends AbstractNamedOperation implements PartitionAwareOperation
Modifier and Type | Field and Description |
---|---|
protected int |
permitCount |
protected Object |
response |
name
CALL_ID_LOCAL_SKIPPED, GENERIC_PARTITION_ID
Modifier | Constructor and Description |
---|---|
protected |
SemaphoreOperation() |
protected |
SemaphoreOperation(String name,
int permitCount) |
Modifier and Type | Method and Description |
---|---|
Object |
getResponse() |
SemaphoreContainer |
getSemaphoreContainer() |
String |
getServiceName() |
void |
readInternal(ObjectDataInput in) |
void |
writeInternal(ObjectDataOutput out) |
getName
afterRun, beforeRun, returnsResponse
getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getPartitionId, getReplicaIndex, getResponseHandler, getService, getWaitTimeout, isUrgent, logError, onException, readData, run, setCallerUuid, setNodeEngine, setPartitionId, setReplicaIndex, setResponseHandler, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionId
protected int permitCount
protected transient Object response
protected SemaphoreOperation()
protected SemaphoreOperation(String name, int permitCount)
public String getServiceName()
getServiceName
in class Operation
public Object getResponse()
getResponse
in class AbstractOperation
public SemaphoreContainer getSemaphoreContainer()
public void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class AbstractNamedOperation
IOException
public void readInternal(ObjectDataInput in) throws IOException
readInternal
in class AbstractNamedOperation
IOException
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.