Skip to content

Instantly share code, notes, and snippets.

@Hemanthdev

Hemanthdev/subscription_by_queue_arn.sh

Forked from jbrechtel/subscription_by_queue_arn.sh
Created April 22, 2022 10:58
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save Hemanthdev/b3b8580548124b1033da48b29951cfc1 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save Hemanthdev/b3b8580548124b1033da48b29951cfc1 to your computer and use it in GitHub Desktop.
Download ZIP
goaws SNS -> SQS subscription
Raw
subscription_by_queue_arn.sh
#!/bin/sh
echo "CREATING SUBSCRIPTION WITH QUEUE ARN"
set -e
ENDPOINT_URL="http://localhost:4100"
export AWS_DEFAULT_REGION="us-east-1"
export AWS_SECRET_ACCESS_KEY="fakefakefake"
export AWS_ACCESS_KEY_ID="faketyfakefake"
TOPIC_ARN=$(aws --endpoint-url $ENDPOINT_URL sns create-topic --name test-topic | jq -r ".TopicArn")
echo "TOPIC_ARN: $TOPIC_ARN"
QUEUE_URL=$(aws --endpoint-url $ENDPOINT_URL sqs create-queue --queue-name test-queue | jq -r ".QueueUrl")
echo "QUEUE_URL: $QUEUE_URL"
QUEUE_ARN=$(aws --endpoint-url $ENDPOINT_URL sqs get-queue-attributes --queue-url $QUEUE_URL | jq -r ".Attributes.QueueArn")
echo "QUEUE_ARN: $QUEUE_ARN"
aws --endpoint-url $ENDPOINT_URL sns subscribe --topic-arn $TOPIC_ARN --protocol sqs --notification-endpoint $QUEUE_ARN
aws --endpoint-url $ENDPOINT_URL sns publish --topic-arn $TOPIC_ARN --message test-message
echo "RECEIVING MESSAGE"
aws --endpoint-url $ENDPOINT_URL sqs receive-message --queue-url $QUEUE_URL
Raw
subscription_by_queue_url.sh
#!/bin/sh
echo "CREATING SUBSCRIPTION WITH QUEUE URL"
set -e
ENDPOINT_URL="http://localhost:4100"
export AWS_DEFAULT_REGION="us-east-1"
export AWS_SECRET_ACCESS_KEY="fakefakefake"
export AWS_ACCESS_KEY_ID="faketyfakefake"
TOPIC_ARN=$(aws --endpoint-url $ENDPOINT_URL sns create-topic --name test-topic | jq -r ".TopicArn")
echo "TOPIC_ARN: $TOPIC_ARN"
QUEUE_URL=$(aws --endpoint-url $ENDPOINT_URL sqs create-queue --queue-name test-queue | jq -r ".QueueUrl")
echo "QUEUE_URL: $QUEUE_URL"
QUEUE_ARN=$(aws --endpoint-url $ENDPOINT_URL sqs get-queue-attributes --queue-url $QUEUE_URL | jq -r ".Attributes.QueueArn")
echo "QUEUE_ARN: $QUEUE_ARN"
aws --endpoint-url $ENDPOINT_URL sns subscribe --topic-arn $TOPIC_ARN --protocol sqs --notification-endpoint $QUEUE_URL
aws --endpoint-url $ENDPOINT_URL sns publish --topic-arn $TOPIC_ARN --message test-message
echo "RECEIVING MESSAGE"
aws --endpoint-url $ENDPOINT_URL sqs receive-message --queue-url $QUEUE_URL
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment