File tree 2 files changed +5
-2
lines changed
src/Symfony/Component/Messenger/Transport/Receiver
2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change 11
11
12
12
namespace Symfony \Component \Messenger \Transport \Receiver ;
13
13
14
+ use Symfony \Component \Messenger \Envelope ;
14
15
use Symfony \Component \Messenger \Exception \TransportException ;
15
16
16
17
/**
19
20
interface BlockingReceiverInterface extends ReceiverInterface
20
21
{
21
22
/**
22
- * @param callable(\AMQPEnvelope ):bool $callback If callback return false, then processing thread will be
23
+ * @param callable(Envelope ):bool $callback If callback return false, then processing thread will be
23
24
* returned to PHP script.
24
25
*
25
26
* @throws TransportException If there is an issue communicating with the transport
Original file line number Diff line number Diff line change 11
11
12
12
namespace Symfony \Component \Messenger \Transport \Receiver ;
13
13
14
+ use Symfony \Component \Messenger \Envelope ;
15
+
14
16
/**
15
17
* Some transports may have multiple queues. This interface is used to read from only some queues in blocking mode.
16
18
*
@@ -22,7 +24,7 @@ interface QueueBlockingReceiverInterface extends BlockingReceiverInterface
22
24
* Pull messages from the specified queue names instead of consuming from all queues.
23
25
*
24
26
* @param string[] $queueNames
25
- * @param callable(\AMQPEnvelope ):bool $callback If callback return false, then processing thread will be
27
+ * @param callable(Envelope ):bool $callback If callback return false, then processing thread will be
26
28
* returned to PHP script.
27
29
*/
28
30
public function pullFromQueues (array $ queueNames , callable $ callback ): void ;
You can’t perform that action at this time.
0 commit comments