Contact Free trial Login

Amazon SQS Connector 5.8 Studio Configuration - Mule 4

Anypoint Studio (Studio) editors help you design and update your Mule applications, properties, and configuration files.

To add and configure a connector in Studio:

When you run the connector, you can view the app log to check for problems, as described in View the App Log.

If you are new to configuring connectors in Studio, see Use Studio to Configure a Connector. If, after reading this topic, you need additional information about the connector fields, see the <link to the connector Reference Guide [<connector name> Reference].

Create a Mule Project

In Studio, create a new Mule project in which to add and configure the connector:

  1. In Studio, select File > New > Mule Project.

  2. Enter a name for your Mule project and click Finish.

Add the Connector to Your Mule Project

Add Amazaon SQS Connector to your Mule project to automatically populate the XML code with the connector’s namespace and schema location and add the required dependencies to the project’s pom.xml file:

  1. In the Mule Palette view, click (X) Search in Exchange.

  2. In Add Modules to Project, type amazon sqs in the search field.

  3. Click Amazon SQS in Available modules.

  4. Click Add.

  5. Click Finish.

Adding a connector to a Mule project in Studio does not make that connector available to other projects in your Studio workspace.

Configure a Source

A source initiates a flow when a specified condition is met. You can configure one of these input sources to use with Amazon SQS Connector:

  • Receive messages
    Retrieves one or more messages from the specified queue

  • HTTP > Listener
    Initiates a flow each time it receives a request on the configured host and port

  • Scheduler
    Initiates a flow when a time-based condition is met

For example, to configure the Receive messages source operation, follow these steps:

  1. In the Mule Palette view, select Amazon SQS > Receive messages.

  2. Drag Receive messages to the Studio canvas.

  3. On the Receive messages configuration screen, optionally change the value of the Display Name field.

  4. Specify values for the following fields:

    • Visibility Timeout
      Period of time during which other consumers are prevented from receiving and processing the same message in the queue

    • Visibility Timeout unit
      The time unit for the Visibility Timeout:

      • NANOSECONDS

      • MICROSECONDS

      • MILLISECONDS

      • SECONDS

      • MINUTES

      • HOURS

      • DAYS

    • Preserve Messages
      Preserve messages after they are read rather than immediately deleting them from the queue after they are read

    • Number Of Messages
      Number of messages to retrive

    • Queue Url
      URL of the queue in which to receive messages

  5. If you are using the Receive messages source in cluster mode and want to receive messages on the primary node only, select the Primary node only checkbox on the Receive messages > Advanced tab:

    Read message configuration Advanced tab with Primary node only option selected

    For more information, see Receiving Messages in Cluster Mode.

Configure a Global Element for the Connector

When you configure a connector, it’s best to configure a global element that all instances of that connector in the app can use. Configuring a global element requires you to provide the authentication credentials the connector uses to access the target Amazon SQS system. Amazon SQS supports the Basic and Role authentication methods for connections.

You can either enter your credentials into the global configuration properties or reference a configuration placed in a file in the src folder of your project file that contains these values. For simpler maintenance and better reuse of your project, use a configuration file.

  1. Drag a connector operation onto the Studio canvas.

  2. To create a global element for the connector, click the Global Elements tab at the base of the canvas, and then click Create.

  3. In the Choose Global Type window, expand Connector Configuration and select Amazon SQS Configuration:

    Select Connector for Global Element
  4. Click OK.

  5. Specify the global element properties:

    Configure Global Element
    Field Description

    Name

    Name used to reference the configuration

    Session Token

    Session token used to validate the temporary security credentials

    Access Key

    Alphanumeric text string that uniquely identifies the user who owns the account

    Secret Key

    Key that acts as a password

    Try AWS Credentials Provider Chain

    Drop-down menu that controls whether to use temporary credentials

    Region Endpoint

    Regional endpoint to process your requests

    Default Global URL

    URL of the Amazon SQS queue to act upon

    When you provide a queue URL in the Default Global Queue URL field of the global element, the connector automatically creates the queue and sets the URL of this queue as the provided value. All Amazon SQS message processors that reference the global element perform operations using this queue URL.

    To reference a different queue URL for a particular message processor in the flow, perform the operation using the Queue URL attribute provided by the message processor.

  6. Leave the default entries for the Proxy tab.

  7. Click Test Connection to confirm that the parameters of your global configuration are accurate and that Mule is able to connect successfully to your instance of Amazon SQS.
    To test the connection, you must specify a value for the Test Queue Arn field in the configuration. If a value is not specified, the test connection is not performed, and the console displays a warning when the operation is invoked.

  8. Click OK.

View the App Log

To check for problems, you can view the app log as follows:

  • If you’re running the app from Anypoint Platform, the output is visible in the Anypoint Studio console window.

  • If you’re running the app using Mule from the command line, the app log is visible in your OS console.

Unless the log file path is customized in the app’s log file (log4j2.xml), you can also view the app log in the default location MULE_HOME/logs/<app-name>.log.

Next Step

After configuring this connector in Studio, see Additional Configuration Information for more configuration steps.