Examples of com.amazonaws.services.simpleworkflow.flow.core.Task

Package com.amazonaws.services.simpleworkflow.flow.core

Examples of com.amazonaws.services.simpleworkflow.flow.core.Task

com.amazonaws.services.simpleworkflow.flow.core.Task
Asynchronous task that is executed when all {@link Promise}s passed to its constructor are ready (null parameter is considered ready).
Should be created in the context of {@link AsyncScope#doAsync()} method, from{@link Task#doExecute()} or from {@link TryCatchFinally} do... methods.Exceptions thrown from {@link #doExecute()} are delivered asynchronously tothe wrapping {@link TryCatchFinally#doCatch(Throwable)} method or rethrownfrom {@link AsyncScope#eventLoop()} if no wrapping {@link TryCatchFinally} isfound.
Example of using {@link Task} to implement asynchronous function that sumsparameters when both of them are ready:
```
  public Promise<Integer> sum(Promise<Integer> a, Promise<Integer> b) { Settable<Integer> result = new Settable<Integer>(); new Task(a, b) { public void doExecute() { result.set(a.get() + b.get()); } }; return result; }  
```
@see AsyncScope @see TryCatchFinally @see Promise

            protected void doFinally() throws Throwable {
                shouldRetry.set(failureToRetry);
            }
        };


        new Task(shouldRetry) {


            @Override
            protected void doExecute() throws Throwable {
                Throwable failure = shouldRetry.get();
                if (failure != null) {

View Full Code Here

            workflowAsyncScope = new UnhandledSignalAsyncScope(workflowAsyncScope.getOutput(), workflowAsyncScope.getFailure(),
                    workflowAsyncScope.isCancelRequested());
            completed = false;
        }
        // This task is attached to the root context of the workflowAsyncScope
        new Task(workflowAsyncScope) {


            @Override
            protected void doExecute() throws Throwable {
                definition.signalRecieved(signalAttributes.getSignalName(), signalAttributes.getInput());
            }

View Full Code Here


    @Test
    public void testThroughClientAssertWithTask() throws Exception {
        HelloWorldWorkflowClient workflow = workflowFactory.getClient();
        Promise<Void> done = workflow.helloWorld("AWS");
        new Task(done) {


            @Override
            protected void doExecute() throws Throwable {
                Assert.assertEquals("Hello AWS!", activitiesImplementation.getGreeting());
            }

View Full Code Here

    }


    @Override
    public void requestCancelWorkflowExecution(Promise<?>... waitFor) {
        checkWorkflowExecution();
        new Task(waitFor) {


            @Override
            protected void doExecute() throws Throwable {
                GenericWorkflowClient client = getGenericClientToUse();
                client.requestCancelWorkflowExecution(workflowExecution);

View Full Code Here

                        schedulingOptions, startOptionsOverride);
                GenericWorkflowClient client = getGenericClientToUse();
                reply = client.startChildWorkflow(startParameters);
                runId.setDescription("runId of " + reply.getDescription());
                result.setDescription(reply.getDescription());
                new Task(reply) {


                    @Override
                    protected void doExecute() throws Throwable {
                        if (!runId.isReady()) {
                            runId.set(reply.get().getRunId());

View Full Code Here

    }


    @Override
    public void signalWorkflowExecution(final String signalName, final Object[] arguments, Promise<?>... waitFor) {
        checkWorkflowExecution();
        new Task(waitFor) {


            @Override
            protected void doExecute() throws Throwable {
                SignalExternalWorkflowParameters parameters = new SignalExternalWorkflowParameters();
                parameters.setSignalName(signalName);

View Full Code Here

        if (currentCommandTryCatchFinally != null) {
            // Skip duplicated calls to cancelCurrentAndReexecute
            if (commandDone == null) {
                commandDone = new Settable<Void>();
                currentCommandTryCatchFinally.cancel(null);
                new Task(commandDone) {


                    @Override
                    protected void doExecute() throws Throwable {
                        if (cancelledDueToRetryRequest) {
                            execute(command);

View Full Code Here

    public Promise<Void> waitBlocked(Promise<?>... waitFor) {
        if (scope == null) {
            throw new IllegalArgumentException("Called outside of test method");
        }
        final Settable<Void> result = new Settable<Void>();
        new Task(waitFor) {


            @Override
            protected void doExecute() throws Throwable {
                waits.add(result);
            }

View Full Code Here

    public void clockAdvanceSeconds(final long seconds) {
        workflowClock.advanceSeconds(seconds);
    }


    public void clockAdvanceSeconds(final long seconds, Promise<?>... waitFor) {
        new Task(waitFor) {


            @Override
            protected void doExecute() throws Throwable {
                workflowClock.advanceSeconds(seconds);
            }

View Full Code Here

    static public void assertNotReady(Promise<?> condition) {
        Assert.assertFalse(condition.isReady());
    }


    static public void assertTrueWaitFor(final String message, final boolean condition, Promise<?>... waitFor) {
        new Task(waitFor) {


            @Override
            protected void doExecute() throws Throwable {
                Assert.assertTrue(message, condition);
            }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of com.amazonaws.services.simpleworkflow.flow.core.Task

com.amazonaws.services.simpleworkflow.flow.DynamicWorkflowClientImpl

com.amazonaws.services.simpleworkflow.flow.examples.helloworld.HelloWorldTest

com.amazonaws.services.simpleworkflow.flow.interceptors.AsyncCancelAndRetryExecutor

com.amazonaws.services.simpleworkflow.flow.interceptors.AsyncRetryingExecutor

com.amazonaws.services.simpleworkflow.flow.interceptors.AsyncScheduledExecutor

com.amazonaws.services.simpleworkflow.flow.interceptors.RetryInterceptorVoid

com.amazonaws.services.simpleworkflow.flow.interceptors.RetryInterceptorWithResult

com.amazonaws.services.simpleworkflow.flow.junit.AsyncAssert

com.amazonaws.services.simpleworkflow.flow.junit.WorkflowTestBase

com.amazonaws.services.simpleworkflow.flow.test.TestGenericWorkflowClient

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.