Examples of execute()

Examples of com.googlecode.batchfb.util.RequestBuilder.execute()

70
71
72
73
74
75
76
77
78
79
80
    RequestBuilder request = new RequestBuilder(VERIFY_LINK, HttpMethod.POST);
    request.addParam("assertion", assertion);
    request.addParam("audience", audience);

    HttpResponse response = request.execute();
    if (response.getResponseCode() != HttpServletResponse.SC_OK)
      throw new IllegalStateException("Bad response code: " + response.getResponseCode());

    Assertion result = MAPPER.readValue(response.getContentStream(), Assertion.class);
View Full Code Here

Examples of com.googlecode.goclipse.ui.actions.GocodeClient.execute()

68
69
70
71
72
73
74
75
76
77
78
     
      // TODO: we should run this operation outside the UI thread.
      IProgressMonitor pm = new TimeoutProgressMonitor(5000, true);
      GocodeClient client = new GocodeClient(gocodePath.toOSString(), goEnvironment, pm);
     
      ExternalProcessResult processResult = client.execute(filePath, document.get(), offset);
      String stdout = processResult.getStdOutBytes().toString(StringUtil.UTF8);
      List<String> completions = new ArrayList2<>(GocodeClient.LINE_SPLITTER.split(stdout));
     
      CodeContext codeContext = codeContexts.get(filePath);
      if (codeContext == null) {
View Full Code Here

Examples of com.googlecode.prolog_cafe.lang.BufferingPrologControl.execute()

44
45
46
47
48
49
50
51
52
53
54
    pcl.setEnabled(EnumSet.allOf(Prolog.Feature.class), false);
    pcl.setEnabled(Prolog.Feature.IO, true);
    pcl.setEnabled(Prolog.Feature.STATISTICS_RUNTIME, true);

    pcl.initialize(Prolog.BUILTIN);
    pcl.execute(Prolog.BUILTIN, "set_prolog_flag",
        SymbolTerm.intern("print_stack_trace"),
        SymbolTerm.intern("on"));

    for (String file : fileName) {
      String path;
View Full Code Here

Examples of com.graphaware.tx.executor.batch.BatchTransactionExecutor.execute()

143
144
145
146
147
148
149
150
151
152
153
        });

        return TestUtils.time(new TestUtils.Timed() {
            @Override
            public void time() {
                executor.execute();
            }
        });
    }

    /**
 
View Full Code Here

Examples of com.graphaware.tx.executor.batch.NoInputBatchTransactionExecutor.execute()

143
144
145
146
147
148
149
150
151
152
153
        });

        return TestUtils.time(new TestUtils.Timed() {
            @Override
            public void time() {
                executor.execute();
            }
        });
    }

    /**
 
View Full Code Here

Examples of com.groupon.odo.bmp.http.BrowserMobHttpRequest.execute()

707
708
709
710
711
712
713
714
715
716
717
                public void reportError(Exception e) {
                    BrowserMobProxyHandler.reportError(e, url, response);
                }
            });

            BrowserMobHttpResponse httpRes = httpReq.execute();

            // ALWAYS mark the request as handled if we actually handled it. Otherwise, Jetty will think non 2xx responses
            // mean it wasn't actually handled, resulting in totally valid 304 Not Modified requests turning in to 404 responses
            // from Jetty. NOT good :(
            request.setHandled(true);
View Full Code Here

Examples of com.hazelcast.client.spi.ClientExecutionService.execute()

246
247
248
249
250
251
252
253
254
255
256
        return sb.toString();
    }

    void fireMembershipEvent(final MembershipEvent event) {
        ClientExecutionService clientExecutionService = client.getClientExecutionService();
        clientExecutionService.execute(new Runnable() {
            @Override
            public void run() {
                for (MembershipListener listener : listeners.values()) {
                    if (event.getEventType() == MembershipEvent.MEMBER_ADDED) {
                        listener.memberAdded(event);
View Full Code Here

Examples of com.hazelcast.core.IExecutorService.execute()

770
771
772
773
774
775
776
777
778
779
780
        config.addExecutorConfig(new ExecutorConfig(name).setQueueCapacity(1).setPoolSize(1));
        final HazelcastInstance instance = createHazelcastInstance(config);
        final IExecutorService executorService = instance.getExecutorService(name);


        executorService.execute(new SleepLatchRunnable());

        assertTrue(SleepLatchRunnable.startLatch.await(30, TimeUnit.SECONDS));
        final Future waitingInQueue = executorService.submit(new EmptyRunnable());

        final Future rejected = executorService.submit(new EmptyRunnable());
View Full Code Here

Examples of com.hazelcast.executor.impl.DistributedExecutorService.execute()

83
84
85
86
87
88
89
90
91
92
93
    }

    @Override
    public final void run() throws Exception {
        DistributedExecutorService service = getService();
        service.execute(name, uuid, callable, getResponseHandler());
    }

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

Examples of com.hazelcast.spi.impl.InternalOperationService.execute()

146
147
148
149
150
151
152
153
154
155
156
        int partitionId = packet.getPartitionId();
        if (partitionId < 0) {
            executor.execute(new ClientPacketProcessor(packet));
        } else {
            InternalOperationService operationService = (InternalOperationService) nodeEngine.getOperationService();
            operationService.execute(new ClientPacketProcessor(packet), packet.getPartitionId());
        }
    }

    @Override
    public InternalPartitionService getPartitionService() {
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.