JarCastingSQS-Connect
is a JCA adapter for Amazon SQS.
Using
To use the connector in your project add the following dependency to your pom.xml:
<dependency>
<groupid>ninja.seibert</groupid>
<artifactId>sqsconnect-api</artifactId>
<version>1.0</version>
</dependency>
After that you should deploy the rar archive to your application server.
Inbound
To receive messages you have to create an MDB like this:
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "accessKeyId", propertyValue = "<yourAccessKeyId>"),
@ActivationConfigProperty(propertyName = "secretAccessKey", propertyValue = "<yourSecretAccessKey>"),
@ActivationConfigProperty(propertyName = "region", propertyValue = "<yourRegion>"),
@ActivationConfigProperty(propertyName = "queueURL", propertyValue = "<yourQueueUrl>")
})
public class SqsMessageReceiver implements SqsListener {
@Override
public void onMessage(Message message) {
//Your message processing code here
}
}
If you already set accessKeyId, secretAccessKey or region in the resource adapter config you can omit them here.
Outbound
You can create an outbound connection by creating an SqsConnectionFactory (either in your application server or by using the @ConnectionDefinition annotation). After that you can send messages like this:
try (SqsConnection connection = factory.getConnection()) {
connection.sendMessage(new SendMessageRequest("<yourQueueUrl>", "<yourContent>"));
} catch (ResourceException e) {
//Problem while allocating the connection
} catch (Exception e) {
//General problem while sending the message or closing the connection
}
Configuration Properties
You can define the following configuration properties in the resource adapter config or ConnectionFactory setup of your application server to be able to omit them in the annotations.
| Property | Type | Default | Description |
|---|---|---|---|
| accessKeyId | String | none | The accessKeyId used to connect to SQS. |
| secretAccessKey | String | none | The secretAccessKey used to connect to SQS. |
| maxMessages | Integer | 10 | Maximum number of messages to pull at once (min. 1, max. 10). |
| pollInterval | Integer | 30 | Number of seconds to wait between polls. |
| region | String | none | Region your queue is hosted in. |
Note that maxMessages and pollInterval only apply to MDB configuration.
Building
You can build the adapter yourself by cloning this repo
git clone https://github.com/se1by/SQS-Connect.git
and executing
mvn clean package
in the project root.