diff --git a/lib/index.ts b/lib/index.ts index 57a0f62..64d82b2 100644 --- a/lib/index.ts +++ b/lib/index.ts @@ -412,8 +412,11 @@ export class RedisAdapter extends Adapter { } called = true; debug("calling acknowledgement with %j", arg); + const responseChannel = this.publishOnSpecificResponseChannel + ? `${this.responseChannel}${request.uid}#` + : this.responseChannel; this.pubClient.publish( - this.responseChannel, + responseChannel, JSON.stringify({ type: RequestType.SERVER_SIDE_EMIT, requestId: request.requestId,