Package com.hazelcast.concurrent.lock.operations

Examples of com.hazelcast.concurrent.lock.operations.LocalLockCleanupOperation


            }
        }
    }

    private void sendUnlockOperation(LockStoreContainer container, LockStoreImpl lockStore, Data key) {
        UnlockOperation op = new LocalLockCleanupOperation(lockStore.getNamespace(), key, -1);
        op.setAsyncBackup(true);
        op.setNodeEngine(nodeEngine);
        op.setServiceName(SERVICE_NAME);
        op.setService(LockServiceImpl.this);
        op.setResponseHandler(ResponseHandlerFactory.createEmptyResponseHandler());
        op.setPartitionId(container.getPartitionId());
        op.setValidateTarget(false);
        nodeEngine.getOperationService().executeOperation(op);
    }
View Full Code Here


            }
        }
    }

    private void sendUnlockOperation(LockStoreContainer container, LockStoreImpl lockStore, Data key) {
        UnlockOperation op = new LocalLockCleanupOperation(lockStore.getNamespace(), key, -1);
        op.setAsyncBackup(true);
        op.setNodeEngine(nodeEngine);
        op.setServiceName(SERVICE_NAME);
        op.setService(LockServiceImpl.this);
        op.setResponseHandler(ResponseHandlerFactory.createEmptyResponseHandler());
        op.setPartitionId(container.getPartitionId());
        op.setValidateTarget(false);
        nodeEngine.getOperationService().executeOperation(op);
    }
View Full Code Here

TOP

Related Classes of com.hazelcast.concurrent.lock.operations.LocalLockCleanupOperation

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.