Skip to content

Commit 2b0d68a

Browse files
committed
Include the old message data when replacing, so we get the projectId etc.
1 parent 2088fa3 commit 2b0d68a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

apps/webapp/app/v3/marqs/index.server.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -480,7 +480,7 @@ export class MarQS {
480480
const newMessage: MessagePayload = {
481481
version: "1",
482482
// preserve original trace context
483-
data: { ...messageData, ...traceContext },
483+
data: { ...oldMessage.data, ...messageData, ...traceContext },
484484
queue: oldMessage.queue,
485485
concurrencyKey: oldMessage.concurrencyKey,
486486
timestamp: timestamp ?? Date.now(),

0 commit comments

Comments
 (0)