@JmsListener(destination = '${workflow.execution.initiator.queue.name}') @GcsLog void onMessage(SQSTextMessage message) { processMessage(message) }
The above code will listen to the message in the workflow.execution.initiator.queue.name of the AWS SQS instance. After retrieving the message it will send it to processMessage() method.