Examples of io.apigee.trireme.core.NodeScript.execute()

io.apigee.trireme.core.NodeScript.execute()
Run the script and return a Future denoting its status. The script is treated exactly as any other Node.js program -- that is, it runs in a separate thread, and the returned future may be used to track its status or completion.
When the script has run to completion -- which means that has left no timers or "nextTick" jobs in its queue, and the "http" and "net" modules are no longer listening for incoming network connections, then it will exit with a status code. Cancelling the future will make the script exit more quickly and throw CancellationException. It is also OK to interrupt the script.

        NodeScript ns =
            env.createScript("consolelogtest.js", new File("./target/test-classes/tests/consolelogtest.js"),
                             new String[] { "stderr", msg });


        try {
            ScriptFuture f = ns.execute();
            ScriptStatus result = f.get(SCRIPT_TIMEOUT_SECS, TimeUnit.SECONDS);
            assertEquals(0, result.getExitCode());


            String stream = new String(out.toByteArray(), UTF8);
            assertEquals(msg + '\n', stream);

View Full Code Here

                             new String[] { "stdout", msg2 });
        ns2.setSandbox(new Sandbox().setStdout(out2));


        try {
            ScriptFuture f1 = ns1.execute();
            ScriptFuture f2 = ns2.execute();


            ScriptStatus result1 = f1.get(SCRIPT_TIMEOUT_SECS, TimeUnit.SECONDS);
            assertEquals(0, result1.getExitCode());
            ScriptStatus result2 = f2.get(SCRIPT_TIMEOUT_SECS, TimeUnit.SECONDS);
            assertEquals(0, result2.getExitCode());

View Full Code Here

            env.createScript("consolelogtest.js", new File("./target/test-classes/tests/consolelogtest.js"),
                             new String[] { "stdout", msg2 });


        try {
            ScriptFuture f1 = ns1.execute();
            ScriptFuture f2 = ns2.execute();


            ScriptStatus result1 = f1.get(SCRIPT_TIMEOUT_SECS, TimeUnit.SECONDS);
            assertEquals(0, result1.getExitCode());
            ScriptStatus result2 = f2.get(SCRIPT_TIMEOUT_SECS, TimeUnit.SECONDS);
            assertEquals(0, result2.getExitCode());

View Full Code Here

        NodeScript script = env.createScript(scriptFile.getName(),
                                             scriptFile,
                                             new String[] {
                                                     scriptFile.getCanonicalPath()
                                             });
        ScriptStatus status = script.execute().get();
        assertEquals(0, status.getExitCode());
        script.close();
    }
}

View Full Code Here

        throws InterruptedException, ExecutionException, NodeException
    {
        NodeScript script = env.createScript("test.js",
                                             "console.log(\'Hello, World!\');process.exit(0);  ",
                                             null);
        ScriptStatus stat = script.execute().get();
        assertEquals(0, stat.getExitCode());
    }


    @Test
    public void testModuleLoad()

View Full Code Here

    {
        NodeScript script = env.createScript("moduletest",
                                             new File("./target/test-classes/tests/moduletest.js"),
                                             null);
        script.setDisplayName("ModuleLoadDisplayNameTest");
        ScriptStatus status = script.execute().get();
        assertEquals(0, status.getExitCode());
        script.close();
    }


    @Test

View Full Code Here

        assertNotNull(modIn);
        String source = Utils.readStream(modIn);
        NodeScript script = env.createScript("moduleteststring.js",
                                             source,
                                             null);
        ScriptStatus stat = script.execute().get();
        assertEquals(0, stat.getExitCode());
    }


    @Test
    public void testBuffer()

View Full Code Here

        throws InterruptedException, ExecutionException, NodeException
    {
        NodeScript script = env.createScript("endless.js",
                                             new File("./target/test-classes/tests/endless.js"),
                                             null);
        final ScriptFuture status = script.execute();
        status.setListener(new ScriptStatusListener()
        {
            @Override
            public void onComplete(NodeScript script, ScriptStatus s)
            {

View Full Code Here

        throws InterruptedException, ExecutionException, NodeException
    {
        NodeScript script = env.createScript("endless.js",
                                             new File("./target/test-classes/tests/endless.js"),
                                             null);
        final ScriptFuture status = script.execute();
        status.setListener(new ScriptStatusListener()
        {
            @Override
            public void onComplete(NodeScript script, ScriptStatus s)
            {

View Full Code Here

        throws InterruptedException, ExecutionException, NodeException
    {
        NodeScript script = env.createScript("endless.js",
                                             new File("./target/test-classes/tests/endless.js"),
                                             null);
        final ScriptFuture status = script.execute();
        status.setListener(new ScriptStatusListener()
        {
            @Override
            public void onComplete(NodeScript script, ScriptStatus s)
            {

View Full Code Here

0 1 2 3 4

TOP

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.