diff --git a/src/app/db/surveyDB/api/send_to_extractor_loader/route.ts b/src/app/db/surveyDB/api/send_to_extractor_loader/route.ts
new file mode 100644
index 0000000..37e7c33
--- /dev/null
+++ b/src/app/db/surveyDB/api/send_to_extractor_loader/route.ts
@@ -0,0 +1,22 @@
+import { NextRequest, NextResponse } from "next/server";
+import { sendToQueue } from "@/app/utils/sqs";
+
+export async function POST(req: NextRequest) {
+  try {
+    const { id } = await req.json();
+
+    if (!id) {
+      return NextResponse.json({ error: "Missing id" }, { status: 400 });
+    }
+
+    const resp = await sendToQueue({ id }, { queueName: "extractor-loader-queue" });
+
+    return NextResponse.json(
+      { ok: true, messageId: resp.MessageId },
+      { status: 200 }
+    );
+  } catch (err: any) {
+    console.error("SQS enqueue failed:", err);
+    return NextResponse.json({ error: err.message }, { status: 500 });
+  }
+}
\ No newline at end of file
diff --git a/src/app/db/surveyDB/api/show_all_sqs_available/route.ts b/src/app/db/surveyDB/api/show_all_sqs_available/route.ts
new file mode 100644
index 0000000..c4ba9c3
--- /dev/null
+++ b/src/app/db/surveyDB/api/show_all_sqs_available/route.ts
@@ -0,0 +1,13 @@
+import { NextResponse } from "next/server";
+import { listQueues } from "@/app/utils/sqs";
+
+// Handle GET requests
+export async function GET() {
+  try {
+    const queues = await listQueues(); // optionally pass a prefix
+    return NextResponse.json({ queues }, { status: 200 });
+  } catch (err: any) {
+    console.error(err);
+    return NextResponse.json({ error: err.message }, { status: 500 });
+  }
+}