nocobase/packages/examples/app-plugin-queue-example

@nocobase/app-plugin-queue-example

Queue app plugin example. It publishes to and consumes the queue-example queue through the application's QueueService, which it resolves from queueServiceToken in @nocobase/app-server/queue.

server/providers/queue-example.ts shows the lifecycle a plugin follows:

• boot() reads the configuration key from the plugin's own queueExample.queue setting and passes it to manager() and consumer(); without one, the queue follows queue.default. It calls manager().configure() to set this instance's concurrency, attempts and backoff, and registers two handlers with consume(), each filtered with withChannel(): one takes greeting, the other takes both greeting and digest, so a greeting runs through both.
• The application's queue provider sets the service up after every provider has booted, so publishing starts once the application runs.
• shutdown() awaits every unregister function before the handlers' dependencies go away.

server/service.ts publishes: publish() for one greeting, and publishMany() for two digests whose jobIdProducer derives the job ID from the day, so publishing the same day again adds nothing while the earlier job is still waiting or kept in the history.

Every route requires authentication and is scoped to /queueExample, so it does not depend on contribution order and does not affect Routes mounted later:

Route	Does
POST /api/queueExample/greet	Publishes one greeting, after { "delay": <ms> } (0 to 600000) when given, and answers 202 with { data: { jobId, queue, channel } }
POST /api/queueExample/digests	Publishes this morning's and this evening's digest in one batch and answers 202 with { data: receipts }
GET /api/queueExample/status	Answers { data: { queue, configKey, deliveries } }: what the handlers received since the application started, newest first

An invalid body is answered 400 with reason INVALID_INPUT and the offending field in fieldViolations.

Each route declares itself for the application's API document with describeRoute() from @nocobase/app-server/router: the QueueExample tag, a summary, an operationId (queueExamplePublishGreeting, queueExamplePublishDigests, queueExampleGetStatus) and its responses through dataResponse() and apiErrorResponse() for each status the route can produce. The body is validated with apiValidator('json', GreetInput), which answers the 400 above and documents both the schema and that 400, so the route does not list 400 itself; the response schemas live in server/routes/schemas.ts with .meta({ ref }). A signed-in user reads the document at /api/swagger/docs.

The examples template sets queueExample.queue from QUEUE_EXAMPLE_QUEUE, so QUEUE_EXAMPLE_QUEUE=redis runs the example on the template's redis key while every other queue keeps following queue.default.