Fix AmqpTransport

yceruto · yceruto · commit b8a4d5a2320b · 2018-05-08T10:54:44.000-04:00
diff --git a/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpTransport.php b/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpTransport.php
@@ -43,7 +43,7 @@ public function __construct(EncoderInterface $encoder, DecoderInterface $decoder
      */
     public function receive(callable $handler): void
     {
-        ($this->receiver ?? $this->getReceiver())->receive($hander);
+        ($this->receiver ?? $this->getReceiver())->receive($handler);
     }
 
     /**
@@ -74,6 +74,6 @@ private function getSender()
 
     private function getConnection()
     {
-        return $this->connection = new Connection($this->dsn, $this->options, $this->debug);
+        return $this->connection = Connection::fromDsn($this->dsn, $this->options, $this->debug);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ public function __construct(EncoderInterface $encoder, DecoderInterface $decoder`
`43`	`43`	`*/`
`44`	`44`	`public function receive(callable $handler): void`
`45`	`45`	`{`
`46`		`- ($this->receiver ?? $this->getReceiver())->receive($hander);`
	`46`	`+ ($this->receiver ?? $this->getReceiver())->receive($handler);`
`47`	`47`	`}`
`48`	`48`
`49`	`49`	`/**`
`@@ -74,6 +74,6 @@ private function getSender()`
`74`	`74`
`75`	`75`	`private function getConnection()`
`76`	`76`	`{`
`77`		`- return $this->connection = new Connection($this->dsn, $this->options, $this->debug);`
	`77`	`+ return $this->connection = Connection::fromDsn($this->dsn, $this->options, $this->debug);`
`78`	`78`	`}`
`79`	`79`	`}`