diff --git a/lib/cluster/ClusterSubscriber.ts b/lib/cluster/ClusterSubscriber.ts index f8ecd216..11c1e0b7 100644 --- a/lib/cluster/ClusterSubscriber.ts +++ b/lib/cluster/ClusterSubscriber.ts @@ -74,6 +74,9 @@ export default class ClusterSubscriber { lazyConnect: true }) + // Ignore the errors since they're handled in the connection pool. + this.subscriber.on('error', noop) + // Re-subscribe previous channels var previousChannels = { subscribe: [], psubscribe: [] } if (lastActiveSubscriber) {