fixing mq connection

.github/workflows/ci.yml

@@ -18,7 +18,7 @@ jobs:
         uses: Namoshek/rabbitmq-github-action@v1.1.0
         with:
           version: "3.8.9"
-          ports: "5672:5672 15672:15672"
+          ports: "5672:5672 5671:5671 15672:15672"
           certificates: ${{ github.workspace }}/provision/test_certs
           config: ${{ github.workspace }}/provision/rabbitmq.config
           definitions: ${{ github.workspace }}/provision/definitions.json

tests/AbstractCallbackConsumerTest.php

@@ -398,7 +398,7 @@ function (Envelope $envelope, Queue $queue) use (&$result): DeliveryResult {
      */
     public function it_handles_flush_deferred_after_timeout(): void
     {
-        $connection = $this->createConnection(new ConnectionOptions(['read_timeout' => 1]));
+        $connection = $this->createConnection(new ConnectionOptions(['host' => 'rabbitmq', 'read_timeout' => 1]));
         $channel = $connection->newChannel();
 
         $exchange = $channel->newExchange();

tests/AbstractChannelRecoverTest.php

@@ -88,7 +88,7 @@ public function it_recovers(): void
 
         $queue1->cancel(); // we have to do that to prevent redelivering to the same consumer
 
-        $newConnection = $this->createConnection(new ConnectionOptions(['read_timeout' => 1]));
+        $newConnection = $this->createConnection(new ConnectionOptions(['host' => 'rabbitmq', 'read_timeout' => 1]));
         $channel2 = $newConnection->newChannel();
         $channel2->setPrefetchCount(8);
 

tests/AbstractExchangeTest.php

@@ -268,7 +268,7 @@ public function it_publishes_with_confirms(): void
             $result[] = $errstr;
         });
 
-        $connection = $this->createConnection(new ConnectionOptions(['read_timeout' => 2]));
+        $connection = $this->createConnection(new ConnectionOptions(['host' => 'rabbitmq', 'read_timeout' => 2]));
         $channel = $connection->newChannel();
         $channel->confirmSelect();
 
@@ -381,7 +381,7 @@ public function it_throws_exception_when_negative_wait_confirm_timeout_given():
         $this->expectException(ChannelException::class);
         $this->expectExceptionMessage('Timeout must be greater than or equal to zero.');
 
-        $connection = $this->createConnection(new ConnectionOptions(['read_timeout' => 2]));
+        $connection = $this->createConnection(new ConnectionOptions(['host' => 'rabbitmq', 'read_timeout' => 2]));
         $channel = $connection->newChannel();
         $channel->confirmSelect();
 

tests/AmqpExtension/ChannelTest.php

@@ -56,7 +56,7 @@ public function it_throws_exception_when_cannot_create_channel(): void
         $this->expectException(\Exception::class);
         $this->expectExceptionMessage('Could not create channel. No connection available.');
 
-        $connection = new Connection(new ConnectionOptions());
+        $connection = new Connection(new ConnectionOptions(['host' => 'rabbitmq']));
 
         $connection->newChannel();
     }

tests/AmqpExtension/ConnectionTest.php

@@ -72,7 +72,7 @@ public function it_connects_with_valid_credentials(): void
      */
     public function it_uses_persistent_connection(): void
     {
-        $connection = $this->createConnection(new ConnectionOptions(['persistent' => true]));
+        $connection = $this->createConnection(new ConnectionOptions(['host' => 'rabbitmq', 'persistent' => true]));
 
         $this->assertTrue($connection->isConnected());
 
@@ -100,7 +100,7 @@ public function it_reconnects(): void
      */
     public function it_reconnects_a_persistent_connection(): void
     {
-        $connection = $this->createConnection(new ConnectionOptions(['persistent' => true]));
+        $connection = $this->createConnection(new ConnectionOptions(['host' => 'rabbitmq', 'persistent' => true]));
 
         $this->assertTrue($connection->isConnected());
 
@@ -125,7 +125,7 @@ public function it_returns_internal_connection(): void
      */
     public function it_connects_with_ssl(): void
     {
-        $options = new ConnectionOptions();
+        $options = new ConnectionOptions(['host' => 'rabbitmq']);
         $options->setVhost('/humus-amqp-test');
         $options->setPort(5671);
         $options->setCaCert(__DIR__ . '/../../provision/test_certs/cacert.pem');
@@ -150,7 +150,7 @@ public function it_connects_with_ssl(): void
      */
     public function it_connects_with_only_cacert(): void
     {
-        $options = new ConnectionOptions();
+        $options = new ConnectionOptions(['host' => 'rabbitmq']);
 
         $options->setVhost('/humus-amqp-test');
         $options->setPort(5671);
@@ -173,7 +173,7 @@ public function it_throws_if_cacert_not_set_but_verify_is_set_to_true(): void
         $this->expectException(InvalidArgumentException::class);
         $this->expectExceptionMessage('CA cert not set, so it can\'t be verified.');
 
-        $options = new ConnectionOptions();
+        $options = new ConnectionOptions(['host' => 'rabbitmq']);
 
         $options->setVhost('/humus-amqp-test');
         $options->setPort(5671);

tests/PhpAmqpLib/Helper/CreateConnectionTrait.php

@@ -30,7 +30,7 @@ trait CreateConnectionTrait
     public function createConnection(?ConnectionOptions $options = null): \Humus\Amqp\Connection
     {
         if (null === $options) {
-            $options = new ConnectionOptions();
+            $options = new ConnectionOptions(['host' => 'rabbitmq']);
         }
 
         $options->setVhost('/humus-amqp-test');

tests/PhpAmqpLib/LazyConnectionTest.php

@@ -41,7 +41,7 @@ public function it_returns_internal_connection(): void
     public function createConnection(?ConnectionOptions $options = null): \Humus\Amqp\Connection
     {
         if (null === $options) {
-            $options = new ConnectionOptions();
+            $options = new ConnectionOptions(['host' => 'rabbitmq']);
         }
 
         $options->setVhost('/humus-amqp-test');

tests/PhpAmqpLib/SocketConnectionTest.php

@@ -61,7 +61,7 @@ public function it_returns_internal_connection(): void
     public function createConnection(?ConnectionOptions $options = null): \Humus\Amqp\Connection
     {
         if (null === $options) {
-            $options = new ConnectionOptions();
+            $options = new ConnectionOptions(['host' => 'rabbitmq']);
         }
 
         return new SocketConnection($options);

tests/PhpAmqpLib/SslConnectionTest.php

@@ -57,7 +57,7 @@ public function it_throws_exception_with_invalid_credentials(): void
      */
     public function it_connects_with_only_cacert(): void
     {
-        $options = new ConnectionOptions();
+        $options = new ConnectionOptions(['host' => 'rabbitmq']);
 
         $options->setVhost('/humus-amqp-test');
         $options->setPort(5671);
@@ -131,7 +131,7 @@ public function it_throws_if_cacert_not_set_but_verify_is_set_to_true(): void
         $this->expectException(InvalidArgumentException::class);
         $this->expectExceptionMessage('CA cert not set, so it can\'t be verified.');
 
-        $options = new ConnectionOptions();
+        $options = new ConnectionOptions(['host' => 'rabbitmq']);
 
         $options->setVhost('/humus-amqp-test');
         $options->setPort(5671);
@@ -143,7 +143,7 @@ public function it_throws_if_cacert_not_set_but_verify_is_set_to_true(): void
     public function createConnection(?ConnectionOptions $options = null): \Humus\Amqp\Connection
     {
         if (null === $options) {
-            $options = new ConnectionOptions();
+            $options = new ConnectionOptions(['host' => 'rabbitmq']);
         }
 
         $options->setVhost('/humus-amqp-test');

tests/PhpAmqpLib/StreamConnectionTest.php

@@ -95,7 +95,7 @@ public function it_throws_exception_on_disconnect(): void
     public function createConnection(?ConnectionOptions $options = null): Connection
     {
         if (null === $options) {
-            $options = new ConnectionOptions();
+            $options = new ConnectionOptions(['host' => 'rabbitmq']);
         }
 
         $options->setVhost('/humus-amqp-test');