AWS Messaging Services

AWS Messaging Services Demo.

Quick start

Before you start working with project you have to install dependency and prepare configuration.

Run from command line:

npm install
copy .env.local .env

Define configuration in file: .env.

SNS

With SNS demo you can:

1. Create SNS Topic: npm run sns1 or node sns/1_create_topic.js - when you do that, remember about save ARN in variable SNS_TOPIC_ARN (in file: .env).
2. Run example app which will be receive messages: npm run sns2 or node sns/2_run_example_app.js (HTTP server).
3. Subscribe topic: npm run sns3 or node sns/3_subscribe_topic.js (Important: server from #2 have to be run and accessible from Internet)
4. Publish example message: npm run sns4 or node sns/4_publish_message.js (Important: server from #2 have to be runned and accessible from Internet)
5. Delete SNS Topic and all subscription: npm run sns5 or node sns/5_delete_topic.js

SQS

With SQS demo you can:

1. Create SQS queue: npm run sqs1 or node sns/1_create_queue.js - when you do that, remember about save Queue URL in variable SQS_QUEUE_URL (in file: .env).
2. Run example app which will be receive messages: npm run sqs2 or node sns/2_run_example_worker.js (worker).
3. Send example message: npm run sqs3 or node sns/3_send_message.js (Important: worker from #2 have to be run)
4. Delete SQS Queue: npm run sqs4 or node sns/4_delete_queue.js

Kinesis

With Kinesis demo you can:

1. Create Kinesis Stream: npm run kinesis1 or node sns/1_create_stream.js.
2. Run example app which will be receive records: npm run kinesis2 or node sns/2_run_example_worker.js (worker).
3. Put example record: npm run kinesis3 or node sns/3_put_record.js (Important: worker from #2 have to be run)
4. Delete Kinesis Stream: npm run kinesis4 or node sns/4_delete_stream.js