QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 13:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

push & pop action (to get process name in audit)

Browse Source
This commit is contained in:
darin.kelkhoff
2023-02-24 15:44:10 -06:00
parent 94a970b8e8
commit 9be0eb9e76
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/queues/SQSQueuePoller.java
View File

@ -131,6 +131,8 @@ public class SQSQueuePoller implements Runnable
runProcessInput.setFrontendStepBehavior(RunProcessInput.FrontendStepBehavior.SKIP); runProcessInput.setFrontendStepBehavior(RunProcessInput.FrontendStepBehavior.SKIP);
runProcessInput.addValue("bodies", bodies); runProcessInput.addValue("bodies", bodies);
QContext.pushAction(runProcessInput);
RunProcessAction runProcessAction = new RunProcessAction(); RunProcessAction runProcessAction = new RunProcessAction();
RunProcessOutput runProcessOutput = runProcessAction.execute(runProcessInput); RunProcessOutput runProcessOutput = runProcessAction.execute(runProcessInput);
@ -156,6 +158,10 @@ public class SQSQueuePoller implements Runnable
{ {
LOG.warn("Error receiving SQS Messages.", e); LOG.warn("Error receiving SQS Messages.", e);
} }
finally
{
QContext.popAction();
}
} }
} }
catch(Exception e) catch(Exception e)