diff --git a/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php b/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php index 7ce26eec29f87..df1f7ab56901f 100644 --- a/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php +++ b/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php @@ -182,6 +182,7 @@ public function reject(string $id): void public function getMessageCount(): int { try { + $this->client->useTube($this->tube); $tubeStats = $this->client->statsTube($this->tube); } catch (Exception $exception) { throw new TransportException($exception->getMessage(), 0, $exception);