move to functional test

Author: versh23

pkg/stomp/Tests/Functional/StompConnectionFactoryTest.php

@@ -0,0 +1,48 @@
+<?php
+
+
+namespace Enqueue\Stomp\Tests\Functional;
+
+
+use Enqueue\Stomp\StompConnectionFactory;
+use Enqueue\Test\RabbitmqStompExtension;
+use Stomp\Network\Observer\HeartbeatEmitter;
+use Stomp\Network\Observer\ServerAliveObserver;
+
+class StompConnectionFactoryTest extends \PHPUnit\Framework\TestCase
+{
+    use RabbitmqStompExtension;
+
+    public function testShouldNotCreateConnectionWithSendHeartbeat()
+    {
+        $dsn = $this->getDsn() . '&send_heartbeat=2000';
+        $factory = new StompConnectionFactory($dsn);
+        $this->expectException(HeartbeatException::class);
+        $factory->createContext()->getStomp();
+    }
+
+    public function testShouldCreateConnectionWithSendHeartbeat()
+    {
+        $dsn = $this->getDsn() . '&send_heartbeat=2000&read_timeout=1';
+        $factory = new StompConnectionFactory($dsn);
+        $context = $factory->createContext();
+
+        $observers = $context->getStomp()->getConnection()->getObservers()->getObservers();
+        $this->assertAttributeEquals([2000, 0], 'heartbeat', $context->getStomp());
+        $this->assertCount(1, $observers);
+        $this->assertInstanceOf(HeartbeatEmitter::class, $observers[0]);
+    }
+
+    public function testShouldCreateConnectionWithReceiveHeartbeat()
+    {
+        $dsn = $this->getDsn() . '&receive_heartbeat=2000';
+        $factory = new StompConnectionFactory($dsn);
+        $context = $factory->createContext();
+
+        $observers = $context->getStomp()->getConnection()->getObservers()->getObservers();
+        $this->assertAttributeEquals([0, 2000], 'heartbeat', $context->getStomp());
+        $this->assertCount(1, $observers);
+        $this->assertInstanceOf(ServerAliveObserver::class, $observers[0]);
+    }
+
+}

pkg/stomp/Tests/StompConnectionFactoryTest.php

@@ -56,32 +56,4 @@ public function testShouldCreateActiveMQContext()
         $this->assertAttributeEquals(false, 'useExchangePrefix', $context);
     }
 
-    public function testShouldNotCreateConnectionWithSendHeartbeat()
-    {
-        $factory = new StompConnectionFactory(['send_heartbeat' => 2000]);
-        $this->expectException(HeartbeatException::class);
-        $factory->createContext()->getStomp();
-    }
-
-    public function testShouldCreateConnectionWithSendHeartbeat()
-    {
-        $factory = new StompConnectionFactory(['send_heartbeat' => 2000, 'read_timeout' => 1]);
-        $context = $factory->createContext();
-
-        $observers = $context->getStomp()->getConnection()->getObservers()->getObservers();
-        $this->assertAttributeEquals([2000, 0], 'heartbeat', $context->getStomp());
-        $this->assertCount(1, $observers);
-        $this->assertInstanceOf(HeartbeatEmitter::class, $observers[0]);
-    }
-
-    public function testShouldCreateConnectionWithReceiveHeartbeat()
-    {
-        $factory = new StompConnectionFactory(['receive_heartbeat' => 2000]);
-        $context = $factory->createContext();
-
-        $observers = $context->getStomp()->getConnection()->getObservers()->getObservers();
-        $this->assertAttributeEquals([0, 2000], 'heartbeat', $context->getStomp());
-        $this->assertCount(1, $observers);
-        $this->assertInstanceOf(ServerAliveObserver::class, $observers[0]);
-    }
 }

pkg/test/RabbitmqStompExtension.php

@@ -8,9 +8,14 @@
 
 trait RabbitmqStompExtension
 {
+    private function getDsn()
+    {
+        return getenv('RABITMQ_STOMP_DSN');
+    }
+
     private function buildStompContext(): StompContext
     {
-        if (false == $dsn = getenv('RABITMQ_STOMP_DSN')) {
+        if (false == $dsn = $this->getDsn()) {
             throw new SkippedTestError('Functional tests are not allowed in this environment');
         }