Amazon SQS Message

The Amazon SQS (Simple Queue Service) trigger polls an Amazon SQS queue for messages.

The Amazon SQS trigger has two output ports. The success port (✔) can send a message if the trigger polls successfully. The failure port (x) can send a message if the trigger fails to poll.

For more information about the Amazon SQS, see the Amazon SQS Getting Started Guide.

Requirements

To use the Amazon SQS trigger, you need:

  • Amazon Web Services (AWS) security credentials.
  • Permission to receive messages from the queue you want to poll.
  • The URL of the queue you want to poll. If you own the queue, you can find this information by navigating to your queue through the AWS Management Console (see image, below). Otherwise, ask the queue owner for the URL.

    • Mouse-over to view image:

Parameters

Note: See also Working with Parameters in Automations Workflows.

Tip: To test that your parameters work as expected, click Validate.

  • SQS Queue URL: Provide the URL of the queue.
  • AWS Access Key ID and AWS Secret Access Key: Provide your AWS security credentials.
  • Delete Message After Received: If Yes, the trigger deletes the Amazon SQS message from FME Server after it is published. If No, the trigger does not delete the message. (Instead, a corresponding process is responsible for deleting it.)
  • Visibility Timeout: The time, in seconds, beginning when the trigger starts, during which other SQS triggers cannot access the same message from the Amazon SQS queue.

Output Keys

See Also

Key Description
time Event time
source Event type
error.type

(Failure port only) Error type:

  • InvalidMessage: An error occurred while configuring this component, such as missing or malformed values.
  • DeadLetter: An error occured while connecting to an external resource. Examples may include connection issues, invalid credentials, or generic external resource exceptions.
error.message (Failure port only) Error message
message (Success port only) Message content
sqs.md5 (Success port only) Message MD5 digest
sqs.messageId (Success port only) Message ID
sqs.receipt (Success port only) Message receipt handle