fix dsn

Author: versh23

pkg/stomp/Tests/Functional/StompConnectionFactoryTest.php

@@ -1,9 +1,7 @@
 <?php
 
-
 namespace Enqueue\Stomp\Tests\Functional;
 
-
 use Enqueue\Stomp\StompConnectionFactory;
 use Enqueue\Test\RabbitmqStompExtension;
 use Stomp\Network\Observer\HeartbeatEmitter;
@@ -15,15 +13,15 @@ class StompConnectionFactoryTest extends \PHPUnit\Framework\TestCase
 
     public function testShouldNotCreateConnectionWithSendHeartbeat()
     {
-        $dsn = $this->getDsn() . '&send_heartbeat=2000';
+        $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';
+        $dsn = $this->getDsn().'?send_heartbeat=2000&read_timeout=1';
         $factory = new StompConnectionFactory($dsn);
         $context = $factory->createContext();
 
@@ -35,7 +33,7 @@ public function testShouldCreateConnectionWithSendHeartbeat()
 
     public function testShouldCreateConnectionWithReceiveHeartbeat()
     {
-        $dsn = $this->getDsn() . '&receive_heartbeat=2000';
+        $dsn = $this->getDsn().'?receive_heartbeat=2000';
         $factory = new StompConnectionFactory($dsn);
         $context = $factory->createContext();
 
@@ -44,5 +42,4 @@ public function testShouldCreateConnectionWithReceiveHeartbeat()
         $this->assertCount(1, $observers);
         $this->assertInstanceOf(ServerAliveObserver::class, $observers[0]);
     }
-
 }

pkg/stomp/Tests/StompConnectionFactoryTest.php

@@ -6,9 +6,6 @@
 use Enqueue\Stomp\StompContext;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\ConnectionFactory;
-use Stomp\Network\Observer\Exception\HeartbeatException;
-use Stomp\Network\Observer\HeartbeatEmitter;
-use Stomp\Network\Observer\ServerAliveObserver;
 
 class StompConnectionFactoryTest extends \PHPUnit\Framework\TestCase
 {
@@ -55,5 +52,4 @@ public function testShouldCreateActiveMQContext()
         $this->assertAttributeEquals(null, 'stomp', $context);
         $this->assertAttributeEquals(false, 'useExchangePrefix', $context);
     }
-
 }