php-amqplib
diff --git a/Collapse file
‎PhpAmqpLib/Wire/IO/StreamIO.php‎
Copy file name to clipboardExpand all lines: PhpAmqpLib/Wire/IO/StreamIO.php
+21-6Lines changed: 21 additions & 6 deletions b/Collapse file
‎PhpAmqpLib/Wire/IO/StreamIO.php‎
Copy file name to clipboardExpand all lines: PhpAmqpLib/Wire/IO/StreamIO.php
+21-6Lines changed: 21 additions & 6 deletions
diff --git a/Collapse file
‎tests/Unit/Connection/AMQPConnectionConfigTest.php‎
Copy file name to clipboardExpand all lines: tests/Unit/Connection/AMQPConnectionConfigTest.php
-1Lines changed: 0 additions & 1 deletion b/Collapse file
‎tests/Unit/Connection/AMQPConnectionConfigTest.php‎
Copy file name to clipboardExpand all lines: tests/Unit/Connection/AMQPConnectionConfigTest.php
-1Lines changed: 0 additions & 1 deletion
@@ -139,7 +139,7 @@ public function connect()
 
         $options = stream_context_get_options($context);
         if (isset($options['ssl']['crypto_method'])) {
-            $this->enable_crypto();
+            $this->enableCrypto();
         }
 
         $this->heartbeat = $this->initial_heartbeat;
@@ -432,16 +432,31 @@ protected function extract_error_code($message)
         return 0;
     }
 
-    private function enable_crypto(): void
+    /**
+     * @throws AMQPIOException
+     */
+    private function enableCrypto(): void
     {
         $timeout_at = time() + ($this->read_timeout + $this->write_timeout) * 2; // 2 round-trips during handshake
 
-        do {
-            $enabled = stream_socket_enable_crypto($this->sock, true);
-        } while ($enabled !== true && time() < $timeout_at);
+        try {
+            $this->setErrorHandler();
+            do {
+                $enabled = stream_socket_enable_crypto($this->sock, true);
+                if ($enabled === true) {
+                    return;
+                }
+                $this->throwOnError();
+                usleep(1e3);
+            } while ($enabled === 0 && time() < $timeout_at);
+        } catch (\ErrorException $exception) {
+            throw new AMQPIOException($exception->getMessage(), $exception->getCode(), $exception);
+        } finally {
+            $this->restoreErrorHandler();
+        }
 
         if ($enabled !== true) {
-            throw new AMQPIOException('Can not enable crypto');
+            throw new AMQPIOException('Could not enable socket crypto');
         }
     }
 }
@@ -50,7 +50,6 @@ public function external_auth_with_user_credentials()
     public function secure_with_incorrect_crypto_method()
     {
         $this->expectException(AMQPIOException::class);
-        $this->expectExceptionMessage('Can not enable crypto');
 
         $cert_dir = realpath(__DIR__ . "/../../certs");
         $config = new AMQPConnectionConfig();
Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,6 @@ public function external_auth_with_user_credentials()`
`50`	`50`	`public function secure_with_incorrect_crypto_method()`
`51`	`51`	`{`
`52`	`52`	`$this->expectException(AMQPIOException::class);`
`53`		`- $this->expectExceptionMessage('Can not enable crypto');`
`54`	`53`
`55`	`54`	`$cert_dir = realpath(__DIR__ . "/../../certs");`
`56`	`55`	`$config = new AMQPConnectionConfig();`