diff --git a/src/serve/options.ts b/src/serve/options.ts
index d404941..a219226 100644
--- a/src/serve/options.ts
+++ b/src/serve/options.ts
@@ -44,10 +44,12 @@ export const processOptions = <TResponse extends Response = Response, TInitialPa
   );
 
   return {
-    qstashClient: new Client({
-      baseUrl: environment.QSTASH_URL!,
-      token: environment.QSTASH_TOKEN!,
-    }),
+    qstashClient:
+      options?.qstashClient ??
+      new Client({
+        baseUrl: environment.QSTASH_URL!,
+        token: environment.QSTASH_TOKEN!,
+      }),
     onStepFinish: (workflowRunId, _finishCondition, detailedFinishCondition) => {
       if (detailedFinishCondition?.condition === "auth-fail") {
         console.error(AUTH_FAIL_MESSAGE);