Examples of runOperation()

Examples of com.hazelcast.spi.OperationService.runOperation()

80
81
82
83
84
85
86
87
88
89
90
    public void afterRun() throws Exception {
        LockStoreImpl lockStore = getLockStore();
        AwaitOperation awaitResponse = lockStore.pollExpiredAwaitOp(key);
        if (awaitResponse != null) {
            OperationService operationService = getNodeEngine().getOperationService();
            operationService.runOperation(awaitResponse);
        }
        shouldNotify = awaitResponse == null;
    }

    @Override
View Full Code Here

Examples of com.hazelcast.spi.OperationService.runOperation()

237
238
239
240
241
242
243
244
245
246
247
            }
        }
        final PrepareMergeOperation prepareMergeOperation = new PrepareMergeOperation(targetAddress);
        prepareMergeOperation.setNodeEngine(node.nodeEngine).setService(node.getClusterService())
                .setResponseHandler(ResponseHandlerFactory.createEmptyResponseHandler());
        operationService.runOperation(prepareMergeOperation);


        for (MemberImpl member : memberList) {
            if (!member.localMember()) {
                operationService.createInvocationBuilder(ClusterServiceImpl.SERVICE_NAME,
View Full Code Here

Examples of com.hazelcast.spi.OperationService.runOperation()

251
252
253
254
255
256
257
258
259
260
261
        }

        final MergeClustersOperation mergeClustersOperation = new MergeClustersOperation(targetAddress);
        mergeClustersOperation.setNodeEngine(node.nodeEngine).setService(node.getClusterService())
                .setResponseHandler(ResponseHandlerFactory.createEmptyResponseHandler());
        operationService.runOperation(mergeClustersOperation);
    }

    @Override
    public final long getStartTime() {
        return joinStartTime.get();
View Full Code Here

Examples of com.hazelcast.spi.OperationService.runOperation()

579
580
581
582
583
584
585
586
587
588
589
                        .setServiceName(SERVICE_NAME)
                        .setService(ClientEngineImpl.this)
                        .setResponseHandler(createEmptyResponseHandler());

                if (member.localMember()) {
                    operationService.runOperation(op);
                } else {
                    operationService.send(op, member.getAddress());
                }
            }
        }
View Full Code Here

Examples of com.hazelcast.spi.OperationService.runOperation()

93
94
95
96
97
98
99
100
101
102
103
            backupOp.setCallerUuid(getCallerUuid());
            OperationAccessor.setCallerAddress(backupOp, getCallerAddress());
            OperationAccessor.setInvocationTime(backupOp, Clock.currentTimeMillis());

            final OperationService operationService = nodeEngine.getOperationService();
            operationService.runOperation(backupOp);
        }
    }

    @Override
    public void afterRun() throws Exception {
View Full Code Here

Examples of org.aspectj.org.eclipse.jdt.internal.core.SortElementsOperation.runOperation()

329
330
331
332
333
334
335
336
337
338
339
            throw new IllegalArgumentException();
        }
        checkASTLevel(level);
        ICompilationUnit[] compilationUnits = new ICompilationUnit[] { compilationUnit };
        SortElementsOperation operation = new SortElementsOperation(level, compilationUnits, positions, comparator);
        operation.runOperation(monitor);
    }
   
  /**
   * Reorders the declarations in the given compilation unit according to the
   * specified comparator. The caller is responsible for arranging in advance
View Full Code Here

Examples of org.eclipse.jdt.internal.core.CreateFieldOperation.runOperation()

125
126
127
128
129
130
131
132
133
134
135
    String keyField = accessModifier + simpleTypeName + " " + fieldName + ";";
    CreateFieldOperation op = new CreateFieldOperation(componentType, keyField, _force);
    if (_sibling != null) {
      op.createAfter(_sibling);
    }
    op.runOperation(progressMonitor);
  }

  private void createImports(String keyType, String keyParameterType) throws JavaModelException {
    if (BindingReflectionUtils.isImportRequired(keyType)) {
      new CreateImportOperation(keyType, getCompilationUnit(), Flags.AccDefault).runOperation(progressMonitor);
View Full Code Here

Examples of org.eclipse.jdt.internal.core.SortElementsOperation.runOperation()

332
333
334
335
336
337
338
339
340
341
342
            throw new IllegalArgumentException();
        }
        checkASTLevel(level);
        ICompilationUnit[] compilationUnits = new ICompilationUnit[] { compilationUnit };
        SortElementsOperation operation = new SortElementsOperation(level, compilationUnits, positions, comparator);
        operation.runOperation(monitor);
    }

  /**
   * Reorders the declarations in the given compilation unit according to the
   * specified comparator. The caller is responsible for arranging in advance
View Full Code Here

Examples of org.eclipse.jdt.internal.core.SortElementsOperation.runOperation()

330
331
332
333
334
335
336
337
338
339
340
            throw new IllegalArgumentException();
        }
        checkASTLevel(level);
        ICompilationUnit[] compilationUnits = new ICompilationUnit[] { compilationUnit };
        SortElementsOperation operation = new SortElementsOperation(level, compilationUnits, positions, comparator);
        operation.runOperation(monitor);
    }

  /**
   * Reorders the declarations in the given compilation unit according to the
   * specified comparator. The caller is responsible for arranging in advance
View Full Code Here

Examples of org.jitterbit.integration.client.ui.interchange.entity.operation.graph2d.controller.OperationSourceDataRunner.runOperation()

96
97
98
99
100
101
102
103
104
105
106
    private boolean startOperationWithDroppedFile(File droppedFile) {
        InterchangeView view = controller.getView();
        OperationSourceDataRunner runner = new OperationSourceDataRunner(view, opNode);
        if (runner.isApplicableOperation()) {
            runner.runOperation(droppedFile);
            droppedFile = null;
            return true;
        }
        return false;
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.