Merge pull request #2 from PrivateDev/socket

stream to socket

Author: koliesnik

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Connectors/RabbitMQConnector.php

@@ -3,7 +3,7 @@
 namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors;
 
 use Illuminate\Queue\Connectors\ConnectorInterface;
-use PhpAmqpLib\Connection\AMQPStreamConnection;
+use PhpAmqpLib\Connection\AMQPSocketConnection;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 
 class RabbitMQConnector implements ConnectorInterface
@@ -18,7 +18,7 @@ class RabbitMQConnector implements ConnectorInterface
     public function connect(array $config)
     {
         // create connection with AMQP
-        $connection = new AMQPStreamConnection(
+        $connection = new AMQPSocketConnection(
             $config['host'],
             $config['port'],
             $config['login'],

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

@@ -6,7 +6,7 @@
 use Illuminate\Contracts\Queue\Queue as QueueContract;
 use Illuminate\Queue\Queue;
 use PhpAmqpLib\Channel\AMQPChannel;
-use PhpAmqpLib\Connection\AMQPStreamConnection;
+use PhpAmqpLib\Connection\AMQPSocketConnection;
 use PhpAmqpLib\Message\AMQPMessage;
 use PhpAmqpLib\Wire\AMQPTable;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
@@ -41,10 +41,10 @@ class RabbitMQQueue extends Queue implements QueueContract
     private $correlationId;
 
     /**
-     * @param AMQPStreamConnection $amqpConnection
+     * @param AMQPSocketConnection $amqpConnection
      * @param array $config
      */
-    public function __construct(AMQPStreamConnection $amqpConnection, $config)
+    public function __construct(AMQPSocketConnection $amqpConnection, $config)
     {
         $this->connection = $amqpConnection;
         $this->defaultQueue = $config['queue'];