amazon web services - DecisionTaskTimedOut when @Asynchronous annotation is used -

I have some two set actions that need to be executed in parallel. After successful completion, I want to execute another set of activity. I used Task and it was working. But, after using @ asynchronous annotation, I'm getting a decision turnout and no execution does not start its execution. As I AspectJ configuration is working and I can see the following sections in your goal:

AsyncWorkflowImpl $ AjcClosure1.class

AsyncWorkflowImpl $ AjcClosure3.class

AsyncWorkflowImpl $ AjcClosure5 .class

asynchronous version

  public class implements AsyncWorkflow {private AsyncActivitiesClient activitiesClient = new AsyncActivitiesClientImpl (AsyncWorkflowImpl); Private Async2 Actions Client Activities Client 2 = New Async2ActivitiesClientImpl (); @ Override public invalid executability () {promise & lt; Integer & gt; Intermediate = null; Promise & lt; Integer & gt; Intermediate reis 2 = faucet; (Int i = 0; I <5; i ++) {Intermediate = Examination Intermediate (Promos.SproIs (i), Intermediate RS); } For (int i = 0; i  I, Promise & Lt; Integer & gt; Ridge) {Return Activities Client.testAct1 (i); } @in synchronized public promises & lt; Integer & gt; TestIntermediate2 (last promises & lt; integer> i, promise & lt; integer & gt; res) {return activities Client2.testAct1 (i); } Asynchronous Public Zero Test (final promises & lt; integer> res, final promise & lt; integer & gt; res2) {activitiesClient.testAct2 (); }}  

Work Edition

  public class AsyncWorkflowImpl AsyncWorkflow {private AsyncActivitiesClient ActivitiesClient = New Asyncitivets Client Impulse (); Private Async2 Actions Client Activities Client 2 = New Async2ActivitiesClientImpl (); @ Override public invalid executability () {promise & lt; Integer & gt; Intermediate = null; Promise & lt; Integer & gt; Intermediate reis 2 = faucet; Settable & LT; Integer & gt; FinalRes = New Settlement & lt; Integer & gt; (); Settable & LT; Integer & gt; FinalRes2 = New Settlement & lt; Integer & gt; (); For (Int i = 0; I <5; i ++) {Intermediate = Examination Intermediate (I, Intermediate RE); } (Int i = 0; I <5; i ++) {Intermediate Reason 2 = Test Intermediate 2 (i, Intermediate Reason 2); } FinalRes.chain (Intermediate Rhesus); FinalRes2.chain (intermediateRes2); Test (finalRes, finalRes2); } Public promises & lt; Integer & gt; Test Intermediate (Final Integer I, Promise & Lt; Integer> Ridge) {Final Settlement & lt; Integer & gt; TempRes = New Settlement & lt; Integer & gt; (); New Work (Res) throws {@Override protected void doExecute () Throniy (tempRes.chain (activitiesClient.testAct1 (i));}}; return temporary copies;} public promises & lt; int & gt; TestIntermediate2 (final int I promise & lt; throws integer & gt; res) {final Setlet & lt; int & gt; TempRes = new Setlet & lt; int & gt; (); new task (RSC) {@Override protected void doExecute () Throwable (tempRes.chain (activitiesclint 2.testAct1 (i));}}; return temporary copies;} public zero test (finalized Da & LT; integer & gt; Race, Final Promise & LT; integer & gt; res2) {new task (race, res2) {@Override protected void doExecute () throws propellant {activitiesClient.testAct2 ();}}; }}  

Is there a problem in knitting ASTJ? Any suggestion is highly appreciated.

A method is executed when the all types are ready to commit your criteria. reserve parameter that is never ready Because, due to your @ asynchronous methods are never executed. The solution is to inform such standards with the outline that these were not waiting to be reported.

The best way to troubleshoot the workflows that "go stuck" is to see your "asynchronous stack trace" that involves async by throwing marks such as marks of all outstanding tasks. Use for