diff --git a/src/Connection/Aggregate/SentinelReplication.php b/src/Connection/Aggregate/SentinelReplication.php index 83276ed8..f1cbf733 100644 --- a/src/Connection/Aggregate/SentinelReplication.php +++ b/src/Connection/Aggregate/SentinelReplication.php @@ -535,7 +535,7 @@ class SentinelReplication implements ReplicationInterface { $connection = $this->getConnectionInternal($command); - if (!$connection->isConnected() && $this->slaves) { + if (!$connection->isConnected() && ($this->slaves || $this->master)) { $this->assertConnectionRole( $connection, $this->strategy->isReadOperation($command) ? 'slave' : 'master'