module-amazonsqs's Introduction

Ballerina Amazon SQS Connector

Amazon SQS Connector allows you to connect to the Amazon Simple Queue Service (SQS) via REST API from Ballerina.

Compatibility

Ballerina Language Version	Amazon SQS API version
1.0.1	2012-11-05

The following sections provide you with information on how to use the Ballerina Amazon SQS connector.

Contribute To Develop
Working with Amazon SQS Connector Actions
Sample

Contribute To develop

Clone the repository by running the following command

git clone https://github.com/wso2-ballerina/module-amazonsqs.git

Working with Amazon SQS Connector

First, import the wso2/amazonsqs module into the Ballerina project.

import wso2/amazonsqs;

In order for you to use the Amazon SQS Connector, first you need to create an Amazon SQS Client.

Ballerina provides a config module to obtain parameters from the configuration file. Specify the configuration object and create the client as follows.

amazonsqs:Configuration configuration = {
    accessKey: config:getAsString("ACCESS_KEY_ID"),
    secretKey: config:getAsString("SECRET_ACCESS_KEY"),
    region: config:getAsString("REGION"),
    accountNumber: config:getAsString("ACCOUNT_NUMBER")
};

amazonsqs:Client sqsClient = new(configuration);

Sample

import ballerina/log;
import wso2/amazonsqs;

// Add the SQS credentials as the Configuration
amazonsqs:Configuration configuration = {
    accessKey: "<ACCESS_KEY>",
    secretKey: "<SECRET_ACCESS>",
    region: "<REGION>",
    accountNumber: "<ACCOUNT_NUMBER>"
};

amazonsqs:Client sqsClient = new(configuration);

public function main(string... args) {

    // Create a new SQS Standard queue named "newQueue"
    map<string> attributes = {};
    string|error response = sqsClient->createQueue("newQueue", attributes);
    if (response is string) {
        log:printInfo("Created queue URL: " + response);
    } else {
        log:printInfo("Error while creating a queue");
    }

}

Recommend Projects