Skip to content

Commit 5efb2a2

Browse files
committed
[Messenger] Fix AMQP Transport factory & TransportFactoryInterface
1 parent c9afef9 commit 5efb2a2

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

Transport/AmqpExt/AmqpTransportFactory.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public function __construct(EncoderInterface $encoder, DecoderInterface $decoder
3434

3535
public function createTransport(string $dsn, array $options): TransportInterface
3636
{
37-
return new AmqpTransport($this->encoder, $this->decoder, $dsn, $options, $thid->debug);
37+
return new AmqpTransport($this->encoder, $this->decoder, $dsn, $options, $this->debug);
3838
}
3939

4040
public function supports(string $dsn, array $options): bool

Transport/TransportFactoryInterface.php

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,7 @@
2020
*/
2121
interface TransportFactoryInterface
2222
{
23-
public function createReceiver(string $dsn, array $options): ReceiverInterface;
24-
25-
public function createSender(string $dsn, array $options): SenderInterface;
23+
public function createTransport(string $dsn, array $options): TransportInterface;
2624

2725
public function supports(string $dsn, array $options): bool;
2826
}

0 commit comments

Comments
 (0)