Skip to content

Commit f24bc83

Browse files
committed
add failover pns
1 parent 6717cb6 commit f24bc83

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

packages/client/lib/client/commands-queue.ts

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -188,12 +188,13 @@ export default class RedisCommandsQueue {
188188
this.events.emit('moving', afterMs, host, Number(port));
189189
break;
190190
}
191-
case 'MIGRATING': {
192-
console.log('GOT MIGRATING', push.map(p => p.toString()));
191+
case 'MIGRATING':
192+
case 'FAILING_OVER': {
193193
this.events.emit('migrating');
194194
break;
195195
}
196-
case 'MIGRATED': {
196+
case 'MIGRATED':
197+
case 'FAILED_OVER': {
197198
this.events.emit('migrated');
198199
break;
199200
}

0 commit comments

Comments
 (0)