diff --git a/examples/simplequeue/index.ts b/examples/simplequeue/index.ts new file mode 100644 index 0000000..feac348 --- /dev/null +++ b/examples/simplequeue/index.ts @@ -0,0 +1,30 @@ +import { AzureQueueConsumer } from 'az-queue-consumer' +import { readFileSync } from 'node:fs' +import { EOL } from 'node:os' + +// read .env file +;(() => + readFileSync('./.env', { encoding: 'utf-8' }) + .toString() + .split(EOL) + .forEach((env) => { + for (let end = 0; end < env.length; end++) { + if (env.charAt(end) == '=') { + const key = env.slice(0, end) + let value = env.slice(end + 1) + if (value.charAt(0) == "'") value = value.slice(1) + if (value.charAt(value.length - 1) == "'") value = value.slice(0, value.length - 1) + process.env[key] = value + break + } + } + }))() + +const client = new AzureQueueConsumer( + process.env.AZURE_QUEUE_NAME!, + process.env.AZURE_STORAGE_ACCOUNT_CONNECTION_STRING!, + (messages) => { + console.log(messages) + } +) +client.listen() diff --git a/examples/simplequeue/package.json b/examples/simplequeue/package.json new file mode 100644 index 0000000..9393dd6 --- /dev/null +++ b/examples/simplequeue/package.json @@ -0,0 +1,18 @@ +{ + "name": "simplequeue", + "version": "1.0.0", + "description": "", + "main": "index.js", + "scripts": { + "start": "tsx index.ts" + }, + "keywords": [], + "author": "", + "license": "ISC", + "devDependencies": { + "tsx": "^3.13.0" + }, + "dependencies": { + "az-queue-consumer": "^1.0.3" + } +}