io.bpic.aws:aws-sqs-rar

Amazon SQS JMS Resource Adapter

License	GNU AFFERO GENERAL PUBLIC LICENSE
Categories	AWS Container PaaS Providers
GroupId	io.bpic.aws
ArtifactId	aws-sqs-rar
Last Version	1.0.3
Release Date	Jan 5, 2020
Type	rar
Description	Amazon SQS JMS Resource Adapter
Source Code Management	http://github.com/bpicio/aws-sqs-ra/tree/master/aws-sqs-rar

Download aws-sqs-rar

Filename	Size
aws-sqs-rar-1.0.3.pom
aws-sqs-rar-1.0.3.rar	4 MB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/io.bpic.aws/aws-sqs-rar/ -->
<dependency>
    <groupId>io.bpic.aws</groupId>
    <artifactId>aws-sqs-rar</artifactId>
    <version>1.0.3</version>
    <type>rar</type>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/io.bpic.aws/aws-sqs-rar/
implementation 'io.bpic.aws:aws-sqs-rar:1.0.3'

Gradle Kotlin

// https://jarcasting.com/artifacts/io.bpic.aws/aws-sqs-rar/
implementation ("io.bpic.aws:aws-sqs-rar:1.0.3")

Apache Buildr

'io.bpic.aws:aws-sqs-rar:rar:1.0.3'

Apache Ivy

<dependency org="io.bpic.aws" name="aws-sqs-rar" rev="1.0.3">
  <artifact name="aws-sqs-rar" type="rar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='io.bpic.aws', module='aws-sqs-rar', version='1.0.3')
)

Scala SBT

libraryDependencies += "io.bpic.aws" % "aws-sqs-rar" % "1.0.3"

Leiningen

[io.bpic.aws/aws-sqs-rar "1.0.3"]

Dependencies

compile (1)

Group / Artifact	Type	Version
io.bpic.jakartaee.ra » aws-sqs-jca-api	jar	1.0.0-SNAPSHOT

provided (1)

Group / Artifact	Type	Version
org.jboss.ironjacamar : ironjacamar-spec-api	jar	1.2.6.Final

Project Modules

There are no modules declared in this project.

Amazon SQS JMS Resource Adapter

Getting Started

Installation

For Wildfly, copy aws-sqs-rar-[VERSION HERE].rar to your application server deployment folder. In standalone it should be:

$WILDFLY_HOME/standalone/deployments

Either reference the resource adapter on your MDB using:

@ResourceAdapter("aws-sqs-rar-[VERSION HERE].rar")

Or by setting as the default adapter on standalone-full.xml:

<subsystem xmlns="urn:jboss:domain:ejb3:6.0">
    ...
    <mdb>
        <resource-adapter-ref resource-adapter-name="${ejb.resource-adapter-name:activemq-ra.rar}"/>
        ...
    </mdb>
    ...
</subsystem>

Then create a queue:

<subsystem xmlns="urn:jboss:domain:resource-adapters:5.0">
    <resource-adapters>
        <resource-adapter id="aws-sqs-rar-[VERSION HERE].rar">
            <archive>
                aws-sqs-rar-${project.version}.rar
            </archive>
            <transaction-support>NoTransaction</transaction-support>
            <admin-objects>
                <admin-object class-name="io.bpic.aws.sqs.ra.SQSJMSQueue" jndi-name="java:jboss/sqs/queue/QueueName" pool-name="QueuePool">
                    <config-property name="queueName">[QUEUE NAME]</config-property>
                </admin-object>
            </admin-objects>
        </resource-adapter>
    </resource-adapters>
</subsystem>

Inbound MDB

To receive messages you must implement the MessageListener interface.

public class ReceiveSQSMDB implements MessageListener {
   
} 

Also you must set the ActivationConfigProperty values suitable for your MDB.

Valid properties are below.

Config Property Name	Type	Default	Notes
awsAccessKeyId	String	None	Must be set to the access key of your AWS account (Optional)
awsSecretKey	String	None	Must be set to the secret key of your AWS account (Optional)
destination	String	None	JNDI queue name
region	String	None	Must be set to the AWS region name of your queue. (Optional)

Your MDB should contain one method annotated with @OnMessage

A full skeleton MDB is shown below

@MessageDriven(activationConfig = {
    @ActivationConfigProperty(propertyName = "awsAccessKeyId", propertyValue = "${ENV=accessKey}"),
    @ActivationConfigProperty(propertyName = "awsSecretKey", propertyValue = "${ENV=secretKey}"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "${ENV=destination}"),   
    @ActivationConfigProperty(propertyName = "region", propertyValue = "eu-west-2")    
})
@ResourceAdapter("aws-sqs-rar-[VERSION HERE].rar")
public class ReceiveSQSMDB implements MessageListener {

    @OnMessage
    public void receiveMessage(Message message) {
        System.out.println("Got message " + message.getBody());
    }
}

License

This project is licensed under the GNU AGPLv3 License - see the LICENSE.md file for details

BP Internet

Versions

Version
1.0.3 Jan 5, 2020
1.0.2 Jan 5, 2020
1.0.1 Jan 5, 2020
1.0.0 Jan 5, 2020