Examples of execute()


Examples of org.apache.activemq.console.command.store.StoreExporter.execute()

        StoreExporter exporter = new StoreExporter();
        String[] remaining = CommandLineSupport.setOptions(exporter, tokens.toArray(new String[tokens.size()]));
        if (remaining.length > 0) {
          throw new Exception("Unexpected arguments: " + Arrays.asList(remaining));
        }
        exporter.execute();
    }
}
View Full Code Here

Examples of org.apache.activemq.console.command.store.amq.AMQJournalTool.execute()

    
     // 3. start AMQJournalReaderTool and read the journal
     LOG.info("Starting journal audit.");
     AMQJournalTool consumerTool = new AMQJournalTool();
     consumerTool.getDirs().add(new File(DATA_DIR + "Broker1/journal/"));
     consumerTool.execute();    
     LOG.info("journal audit finished.");
      
     // 4. verify cacheSize of VelocityContext internal introspectionCache    
     int cacheSize = getVelocityIntrospectionCacheSize(consumerTool);
     LOG.info("VelocityContext introspectionCacheSize is of size " + cacheSize);
View Full Code Here

Examples of org.apache.activemq.thread.TaskRunnerFactory.execute()

            DiscoveryListener listener;

            @Override
            public void start() throws Exception {
                taskRunner.init();
                taskRunner.execute(new Runnable() {
                    @Override
                    public void run() {
                        listener.onServiceAdd(new DiscoveryEvent(broker2
                                .getVmConnectorURI().toString()));
                    }
View Full Code Here

Examples of org.apache.airavata.core.gfac.provider.Provider.execute()

        try {
            /*
             * Execute
             */
            Map<String, ?> result = provider.execute(context);

            log.debug("After provider execution, try to run post-execution chain");

            /*
             * Fill MessageContext with the output from Provider
View Full Code Here

Examples of org.apache.airavata.core.gfac.services.GenericService.execute()

        }

        invocationContext.setInput(inputParam);
        invocationContext.setOutput(outputParam);
        GenericService service = new PropertyServiceFactory(GfacAPI.REPOSITORY_PROPERTIES).createService();
        service.execute(invocationContext);
        return invocationContext;
    }


}
View Full Code Here

Examples of org.apache.airavata.core.gfac.services.impl.PropertiesBasedServiceImpl.execute()

            ct.setInput(input);
            ct.setOutput(output);

            PropertiesBasedServiceImpl service = new PropertiesBasedServiceImpl();
            service.init();
            service.execute(ct);

            Assert.assertNotNull(ct.getOutput());
            Assert.assertNotNull(ct.getOutput().getValue("echo_output"));
            Assert.assertEquals("hello", ((StringParameterType) ((ActualParameter) ct.getOutput().getValue("echo_output")).getType()).getValue());
View Full Code Here

Examples of org.apache.airavata.gfac.local.provider.impl.LocalProvider.execute()

        LocalDirectorySetupHandler localDirectorySetupHandler = new LocalDirectorySetupHandler();
        localDirectorySetupHandler.invoke(jobExecutionContext);
        LocalProvider localProvider = new LocalProvider();
        localProvider.setMonitorPublisher(new MonitorPublisher(new EventBus()));
        localProvider.initialize(jobExecutionContext);
        localProvider.execute(jobExecutionContext);
        localProvider.dispose(jobExecutionContext);
    }
}
View Full Code Here

Examples of org.apache.ambari.server.api.query.Query.execute()

    query.addProperty("bar/d", "e", null);
    query.addProperty("category", "", null);

    expect(request.getQueryPredicate()).andReturn(predicate);
    query.setUserPredicate(predicate);
    expect(query.execute()).andReturn(result);
    result.setResultStatus(capture(resultStatusCapture));

    replay(request, resource, query, predicate, result);

    //test
View Full Code Here

Examples of org.apache.ant.compress.taskdefs.Unzip.execute()

    public static void unzip(File zip, File dest) {
        Unzip u = new Unzip();
        u.setSrc(zip);
        u.setDest(dest);
        u.execute();
    }

    public static File wget(URL url) throws IOException {
        File zip = Files.createTempFile("tmp", "zip").toFile();
        FileUtils.copyURLToFile(url, zip);
View Full Code Here

Examples of org.apache.ant.dotnet.DotNetExecTask.execute()

        }
        exec.setFailonerror(failOnError);
        exec.internalSetErrorProperty(errorProperty);

        try {
            exec.execute();
        } finally {
            if (generatedFile != null) {
                generatedFile.delete();
            }
        }
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.