diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/queues/SQSQueuePoller.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/queues/SQSQueuePoller.java index 59a4f502..ea42058b 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/queues/SQSQueuePoller.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/queues/SQSQueuePoller.java @@ -131,6 +131,8 @@ public class SQSQueuePoller implements Runnable runProcessInput.setFrontendStepBehavior(RunProcessInput.FrontendStepBehavior.SKIP); runProcessInput.addValue("bodies", bodies); + QContext.pushAction(runProcessInput); + RunProcessAction runProcessAction = new RunProcessAction(); RunProcessOutput runProcessOutput = runProcessAction.execute(runProcessInput); @@ -156,6 +158,10 @@ public class SQSQueuePoller implements Runnable { LOG.warn("Error receiving SQS Messages.", e); } + finally + { + QContext.popAction(); + } } } catch(Exception e)