final OperationService operationService = node.nodeEngine.getOperationService();
final Collection<MemberImpl> memberList = node.getClusterService().getMemberList();
final Collection<Future> calls = new ArrayList<Future>();
for (MemberImpl member : memberList) {
if (!member.localMember()) {
Operation operation = new PrepareMergeOperation(targetAddress);
Future f = operationService.createInvocationBuilder(ClusterServiceImpl.SERVICE_NAME,
operation, member.getAddress()).setTryCount(3).invoke();
calls.add(f);
}
}
waitWithDeadline(calls, 3, TimeUnit.SECONDS, whileWaitMergeExceptionHandler);
final PrepareMergeOperation prepareMergeOperation = new PrepareMergeOperation(targetAddress);
prepareMergeOperation.setNodeEngine(node.nodeEngine).setService(node.getClusterService())
.setResponseHandler(ResponseHandlerFactory.createEmptyResponseHandler());
operationService.runOperationOnCallingThread(prepareMergeOperation);
for (MemberImpl member : memberList) {