connect(); return parent::getSocket(); } /** * {@inheritdoc} */ public function channel($channel_id = null) { $this->connect(); return parent::channel($channel_id); } /** * @return null|\PhpAmqpLib\Wire\IO\AbstractIO */ protected function getIO() { if (!$this->io) { $this->connect(); } return $this->io; } /** * Should the connection be attempted during construction? * * @return bool */ public function connectOnConstruct() { return false; } }