Atlassian Connect SQS Queue

This provides implementations for connecting to an SQS Queue for a connect add-on written in node.

Sample usage

Start up the elasticmq server, which is is a fake SQS server which implements the interface but it is not a full implementation.

import { QueuingService  } from "atlassian-connect-sqs-queue";

var queue = new QueuingService('x', 'x', 'elasticmq', 'http://localhost:9324/queue/somequeue');

queue.newMessageHandler('test_message_id', (message) => {
    console.log("Message received: ", message);
});

queue.startReceivingMessages();

queue.addMessage('test_message_id', {
    payload_key: 'payload_value'
});

Running the examples

java -Dconfig.file=examples/local-elasticmq.conf -jar examples/bin/elasticmq-server-0.10.0.jar

Install babel-cli for simplicity

npm i -g babel-cli

Run one of the example scripts

babel-node examples/simple.js