Shorten example queue URL env var

trevorr · Nov 12, 2022 · acc7fce · acc7fce
1 parent 453edc8
commit acc7fce
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 17 deletions.
diff --git a/.env.sample b/.env.sample
@@ -1,3 +1,3 @@
 AWS_PROFILE=default
 AWS_REGION=us-east-1
-AWS_SQS_INDEX_QUEUE_URL=
+AWS_SQS_QUEUE_URL=
diff --git a/README.md b/README.md
@@ -24,13 +24,13 @@ npm install sqs-reader
 ```ts
 import { SQSReader } from 'sqs-reader';
 
-const { AWS_SQS_INDEX_QUEUE_URL } = process.env;
+const { AWS_SQS_QUEUE_URL } = process.env;
 
-if (!AWS_SQS_INDEX_QUEUE_URL) {
-  throw new Error('AWS_SQS_INDEX_QUEUE_URL is not configured');
+if (!AWS_SQS_QUEUE_URL) {
+  throw new Error('AWS_SQS_QUEUE_URL is not configured');
 }
 
-const queueReader = new SQSReader(AWS_SQS_INDEX_QUEUE_URL, async (message) => {
+const queueReader = new SQSReader(AWS_SQS_QUEUE_URL, async (message) => {
   console.log('Received message', message.MessageId);
 });
 

diff --git a/test/basic.test.ts b/test/basic.test.ts
@@ -1,13 +1,13 @@
 import sleep from 'sleep-cancel';
 import { SQSReader } from '../src';
 
-const { AWS_SQS_INDEX_QUEUE_URL } = process.env;
+const { AWS_SQS_QUEUE_URL } = process.env;
 
-if (!AWS_SQS_INDEX_QUEUE_URL) {
-  throw new Error('AWS_SQS_INDEX_QUEUE_URL is not configured');
+if (!AWS_SQS_QUEUE_URL) {
+  throw new Error('AWS_SQS_QUEUE_URL is not configured');
 }
 
-const queueReader = new SQSReader(AWS_SQS_INDEX_QUEUE_URL, async (message) => {
+const queueReader = new SQSReader(AWS_SQS_QUEUE_URL, async (message) => {
   console.log('Received message', message.MessageId);
 });
 

diff --git a/test/index.test.ts b/test/index.test.ts
@@ -5,10 +5,10 @@ import { expect } from 'chai';
 import crypto from 'crypto';
 import { SQSReader } from '../src';
 
-const { AWS_SQS_INDEX_QUEUE_URL } = process.env;
+const { AWS_SQS_QUEUE_URL } = process.env;
 
-if (!AWS_SQS_INDEX_QUEUE_URL) {
-  throw new Error('AWS_SQS_INDEX_QUEUE_URL is not configured');
+if (!AWS_SQS_QUEUE_URL) {
+  throw new Error('AWS_SQS_QUEUE_URL is not configured');
 }
 
 const sqs = new SQS({ apiVersion: '2012-11-05' });
@@ -32,7 +32,7 @@ describe('SQSReader', function () {
     const barrier = makeBarrier();
     let receivedId;
     let receivedBody;
-    const queueReader = new SQSReader(AWS_SQS_INDEX_QUEUE_URL, async (message) => {
+    const queueReader = new SQSReader(AWS_SQS_QUEUE_URL, async (message) => {
       receivedId = message.MessageId;
       receivedBody = message.Body;
       if (receivedBody === sentBody) {
@@ -46,7 +46,7 @@ describe('SQSReader', function () {
 
     const sendResult = await sqs
       .sendMessage({
-        QueueUrl: AWS_SQS_INDEX_QUEUE_URL,
+        QueueUrl: AWS_SQS_QUEUE_URL,
         MessageBody: sentBody,
       })
       .promise();
@@ -73,7 +73,7 @@ describe('SQSReader', function () {
     });
 
     const queueReader = new SQSReader(
-      AWS_SQS_INDEX_QUEUE_URL,
+      AWS_SQS_QUEUE_URL,
       async (message) => {
         // ignore unexpected messages in case there is pending junk in the queue
         console.log(`Received unexpected message ${message.MessageId}: ${message.Body}`);
@@ -107,7 +107,7 @@ describe('SQSReader', function () {
     let receivedId;
     let receivedBody;
     const queueReader = new SQSReader(
-      AWS_SQS_INDEX_QUEUE_URL,
+      AWS_SQS_QUEUE_URL,
       async (message) => {
         receivedId = message.MessageId;
         receivedBody = message.Body;
@@ -129,7 +129,7 @@ describe('SQSReader', function () {
 
     const sendResult = await sqs
       .sendMessage({
-        QueueUrl: AWS_SQS_INDEX_QUEUE_URL,
+        QueueUrl: AWS_SQS_QUEUE_URL,
         MessageBody: sentBody,
       })
       .promise();