Webhook processing
Acknowledge webhook requests immediately, queue each event, and process it asynchronously with retries and full visibility.
Synchronous handler
RocketStack workflow
Validate the request, normalize the payload, and enqueue the event.
Hold events safely until the processing function is ready.
Run the application logic outside the original webhook request.
Example workflow
Simulated client-side demo with example timings — not production benchmarks.
Example workflow
{
"id": "evt_123",
"type": "payment.completed",
"customerId": "cus_123",
"amount": 4900
}Ready to send an example webhook.
Use the RocketStack HTTP API or generated SDKs. Examples below use real request fields.
Step 1 of 4
Create a queue
Language
Create the queue that will hold webhook events until they are processed.
import { Configuration, QueuesApi } from '@rocketstack/sdk';
const queues = new QueuesApi(
new Configuration({ accessToken: process.env.ROCKETSTACK_API_KEY })
);
// Deploy the Function first, then bind it as the delivery target.
const { data } = await queues.createQueue({
name: 'webhook-events',
deliveryTarget: {
type: 'function',
functionId: process.env.ROCKETSTACK_FUNCTION_ID
}
});
console.log(data.data.queueId);Ready to run this workflow?
Keep your app where it is. Call RocketStack from the webhook route, then return quickly.
App Router route handler that verifies, enqueues, and returns quickly.
// app/api/webhooks/stripe/route.ts
import { headers } from 'next/headers'
export async function POST(request: Request) {
const rawBody = await request.text()
const signature = (await headers()).get('stripe-signature')
// Verify the Stripe signature with your endpoint secret.
// const event = stripe.webhooks.constructEvent(rawBody, signature, process.env.STRIPE_WEBHOOK_SECRET!)
const event = JSON.parse(rawBody)
await fetch(
`https://api.rocketstack.sh/queues/${process.env.ROCKETSTACK_QUEUE_ID}/messages`,
{
method: 'POST',
headers: {
Authorization: `Bearer ${process.env.ROCKETSTACK_API_KEY}`,
'Content-Type': 'application/json'
},
body: JSON.stringify({
payload: event,
idempotencyKey: event.id
})
}
)
return new Response(null, { status: 202 })
}Related reading: Next.js Stripe webhook starter
Next.js starter
Clone a Next.js application with signature verification, RocketStack Queue integration, and asynchronous Function processing.
Principle 1
Store processed event IDs before applying irreversible side effects. Pass the provider event ID as idempotencyKey when enqueueing so duplicate deliveries reuse the same queue message.
Principle 2
Retry network and service failures. Surface invalid payloads for review instead of treating them like transient outages.
Principle 3
A repeated delivery should not charge a customer, send an email, or update state twice.
Principle 4
Use the RocketStack console to identify failed resources and processing errors. Messages that exceed maxReceiveCount move to a dead-letter queue for inspection.
Use RocketStack MCP to create the Queue, deploy the Function, and connect the workflow from an MCP-enabled coding client. This workflow uses RocketStack Queue and Functions.
Add reliable webhook processing to this application using RocketStack.
Requirements:
- Verify incoming webhook requests
- Acknowledge valid requests immediately
- Add each event to a RocketStack Queue
- Deploy a RocketStack Function to process queued events
- Use the webhook event ID to prevent duplicate processing
- Surface processing failures clearly
- Keep secrets in environment variablesEvery RocketStack primitive is available on Free with lower monthly usage allowances.
PRIVATE ALPHA
Bring a real application, complete the setup during a guided session, and help shape the product.
Apply for the alphaFile workflows
Store uploads immediately, then process documents, images, CSVs, or AI tasks asynchronously.
Scheduled work
Run application work once in the future or repeatedly without maintaining workers.
Create a free account, get an API key, and deploy the Queue and Function behind your workflow.