diff --git a/packages/publisher/src/adapters/upstash.test.ts b/packages/publisher/src/adapters/upstash.test.ts
index dc1cecdec..db259b378 100644
--- a/packages/publisher/src/adapters/upstash.test.ts
+++ b/packages/publisher/src/adapters/upstash.test.ts
@@ -372,8 +372,8 @@ describe.concurrent(
       expect(received.date).toEqual(new Date('2024-01-01'))
       expect(received.person).toEqual(new Person('John Doe', new Date('2023-01-01')))
 
-      const keys = await redis.keys(`${(publisher as any).prefix}*`)
-      expect(keys).toContain(`${(publisher as any).prefix}${event}`)
+      const keys = await redis.keys(`${(publisher as any).eventPrefix}*`)
+      expect(keys).toContain(`${(publisher as any).eventPrefix}${event}`)
 
       await unsub1()
     })
@@ -493,7 +493,7 @@ describe.concurrent(
       const onError = vi.fn()
 
       const unsubscribe = await publisher.subscribe(event, listener, { onError })
-      const channel = `${(publisher as any).prefix}${event}`
+      const channel = `${(publisher as any).eventPrefix}${event}`
       const subscription = (publisher as any).subscriptionMap.get(channel)
 
       if (!subscription) {