index.ts

index.ts

import { NodeRuntime } from "@effect/platform-node";
import { Schema } from "@effect/schema";
import { startConsumer } from "consumer";
import { Console, Effect, LogLevel, Logger, pipe } from "effect";

const consumer = startConsumer({
  queueName: "QueueName",
  processFunc: (message) => {
    return Console.log("Treated !!", message);
  },
  schema: Schema.Struct({
    idMessage: Schema.String.pipe(Schema.startsWith("msg_")),
  }),
}).pipe(Logger.withMinimumLogLevel(LogLevel.Debug));

NodeRuntime.runMain(
  pipe(Effect.all([Effect.fork(consumer)]), Effect.andThen(Effect.never)),
);