File tree 2 files changed +5
-5
lines changed
src/Symfony/Component/Messenger
2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change 23
23
interface ReceiverInterface
24
24
{
25
25
/**
26
- * Receive some messages to the given handler.
26
+ * Receives some messages to the given handler.
27
27
*
28
28
* While this method could return an unlimited number of messages,
29
29
* the intention is that it returns only one, or a "small number"
30
30
* of messages each time. This gives the user more flexibility:
31
31
* they can finish processing the one (or "small number") of messages
32
32
* from this receiver and move on to check other receivers for messages.
33
- * If a this method returns too many messages, it could cause a
33
+ * If this method returns too many messages, it could cause a
34
34
* blocking effect where handling the messages received from one
35
35
* call to get() takes a long time, blocking other receivers from
36
36
* being called.
@@ -46,7 +46,7 @@ interface ReceiverInterface
46
46
public function get (): iterable ;
47
47
48
48
/**
49
- * Acknowledge that the passed message was handled.
49
+ * Acknowledges that the passed message was handled.
50
50
*
51
51
* @throws TransportException If there is an issue communicating with the transport
52
52
*/
Original file line number Diff line number Diff line change 21
21
interface WorkerInterface
22
22
{
23
23
/**
24
- * Receive the messages and dispatch them to the bus.
24
+ * Receives the messages and dispatch them to the bus.
25
25
*
26
26
* The $onHandledCallback will be passed the Envelope that was just
27
27
* handled or null if nothing was handled.
@@ -31,7 +31,7 @@ interface WorkerInterface
31
31
public function run (array $ options = [], callable $ onHandledCallback = null ): void ;
32
32
33
33
/**
34
- * Stop receiving messages.
34
+ * Stops receiving messages.
35
35
*/
36
36
public function stop (): void ;
37
37
}
You can’t perform that action at this time.
0 commit comments