diff --git a/src/CommandBusClient.php b/src/CommandBusClient.php index 880f8de..7048c7c 100644 --- a/src/CommandBusClient.php +++ b/src/CommandBusClient.php @@ -144,7 +144,7 @@ class CommandBusClient implements CommandBusInterface { if (!$this->connection) { return new Promise(function (callable $resolve, callable $canceller) { - $canceller("Not connected to command bus."); + $canceller(new \RuntimeException("Not connected to command bus.")); }); }