# Integrate Amazon SQS with Amazon MQ

## Setup

Assuming you have an AWS account with sufficient priviliges to create SQS queues an EC2/Cloud9 instance.

## What are we doing?

We will integrate SQS with AmazonMQ using Apache Camel.

## Add AWS SQS SDK dependencies to maven

```
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-aws</artifactId>
        <version>2.24.2</version>
    </dependency> 
```

## Add SQS bean configuration

```
  <bean id="awsRegion" class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
      <property name="targetClass" value="com.amazonaws.regions.RegionUtils"/>
      <property name="targetMethod" value="getRegion"/>
      <property name="arguments">
          <list>
              <value>${aws.region}</value>
          </list>
      </property>
  </bean>
    
  <bean name="sqsClient" class="com.amazonaws.services.sqs.AmazonSQSAsyncClient">
    <constructor-arg>
        <bean class="com.amazonaws.auth.BasicAWSCredentials">
            <constructor-arg value="${access.key}"/>
            <constructor-arg value="${secret.key}"/>
        </bean>
    </constructor-arg>
    <property name="region" ref="awsRegion"/>
  </bean> 
```

Add the following to ```~/environment/router/main/resources/secrets.properties```. Remember to encrypt the acces.key and secret.key using ```crypt.sh``` script.

The encrypted properties added to properties file using ENC(encrypted text) and they are automatically decrypted when the project is run by exporting encryption key using the CAMEL_MASTER_PASSWORD environment variable.

```
access.key=ENC(encrypted access key)
secret.key=ENC(encrypted secret key)
aws.region=ENC(encrypted region)
```

## Add SQS route

In this example we are copying messages from TIBCO queue to SQS. Changing from to a Amazon MQ endpoint can copy messages from AmazonMQ to SQS.

```
    <route>
      <from uri="tibco:queue:ems.to.amq"/>
      <removeHeaders pattern="JMS*"/>
      <to uri="aws-sqs://sqs1?amazonSQSClient=#sqsClient"/>
    </route>
```

## Run the project 

Now run the project using the following commands. 

```
export CAMEL_MASTER_PASSWORD=<Password supplied by host>
mvn install
mvn camel:run
```