Skip to content

Commit 5f87f55

Browse files
committed
Fix AmqpTransport
1 parent c9afef9 commit 5f87f55

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Transport/AmqpExt/AmqpTransport.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public function __construct(EncoderInterface $encoder, DecoderInterface $decoder
4343
*/
4444
public function receive(callable $handler): void
4545
{
46-
($this->receiver ?? $this->getReceiver())->receive($hander);
46+
($this->receiver ?? $this->getReceiver())->receive($handler);
4747
}
4848

4949
/**
@@ -74,6 +74,6 @@ private function getSender()
7474

7575
private function getConnection()
7676
{
77-
return $this->connection = new Connection($this->dsn, $this->options, $this->debug);
77+
return $this->connection = Connection::fromDsn($this->dsn, $this->options, $this->debug);
7878
}
7979
}

0 commit comments

Comments
 (0)