diff --git a/lib/index.ts b/lib/index.ts
index 57a0f62..748b538 100644
--- a/lib/index.ts
+++ b/lib/index.ts
@@ -97,13 +97,11 @@ export function createAdapter(
 export class RedisAdapter extends Adapter {
   public readonly uid;
   public readonly requestsTimeout: number;
-  public readonly publishOnSpecificResponseChannel: boolean;
   public readonly parser: Parser;
 
   private readonly channel: string;
   private readonly requestChannel: string;
   private readonly responseChannel: string;
-  private readonly specificResponseChannel: string;
   private requests: Map<string, Request> = new Map();
   private ackRequests: Map<string, AckRequest> = new Map();
   private redisListeners: Map<string, Function> = new Map();
@@ -129,8 +127,6 @@ export class RedisAdapter extends Adapter {
 
     this.uid = uid2(6);
     this.requestsTimeout = opts.requestsTimeout || 5000;
-    this.publishOnSpecificResponseChannel =
-      !!opts.publishOnSpecificResponseChannel;
     this.parser = opts.parser || msgpack;
 
     const prefix = opts.key || "socket.io";
@@ -138,7 +134,9 @@ export class RedisAdapter extends Adapter {
     this.channel = prefix + "#" + nsp.name + "#";
     this.requestChannel = prefix + "-request#" + this.nsp.name + "#";
     this.responseChannel = prefix + "-response#" + this.nsp.name + "#";
-    this.specificResponseChannel = this.responseChannel + this.uid + "#";
+    if (opts.publishOnSpecificResponseChannel) {
+      this.responseChannel = this.responseChannel + this.uid + "#";
+    }
 
     const isRedisV4 = typeof this.pubClient.pSubscribe === "function";
     if (isRedisV4) {
@@ -159,7 +157,6 @@ export class RedisAdapter extends Adapter {
         [
           this.requestChannel,
           this.responseChannel,
-          this.specificResponseChannel,
         ],
         this.redisListeners.get("sub"),
         true
@@ -177,7 +174,6 @@ export class RedisAdapter extends Adapter {
       this.subClient.subscribe([
         this.requestChannel,
         this.responseChannel,
-        this.specificResponseChannel,
       ]);
       this.subClient.on(
         "messageBuffer",
@@ -478,11 +474,8 @@ export class RedisAdapter extends Adapter {
    * @private
    */
   private publishResponse(request, response) {
-    const responseChannel = this.publishOnSpecificResponseChannel
-      ? `${this.responseChannel}${request.uid}#`
-      : this.responseChannel;
-    debug("publishing response to channel %s", responseChannel);
-    this.pubClient.publish(responseChannel, response);
+    debug("publishing response to channel %s", this.responseChannel);
+    this.pubClient.publish(this.responseChannel, response);
   }
 
   /**
@@ -915,11 +908,6 @@ export class RedisAdapter extends Adapter {
         this.redisListeners.get("sub"),
         true
       );
-      this.subClient.unsubscribe(
-        this.specificResponseChannel,
-        this.redisListeners.get("sub"),
-        true
-      );
     } else {
       this.subClient.punsubscribe(this.channel + "*");
       this.subClient.off(
@@ -927,11 +915,6 @@ export class RedisAdapter extends Adapter {
         this.redisListeners.get("pmessageBuffer")
       );
 
-      this.subClient.unsubscribe([
-        this.requestChannel,
-        this.responseChannel,
-        this.specificResponseChannel,
-      ]);
       this.subClient.off(
         "messageBuffer",
         this.redisListeners.get("messageBuffer")