fixed typos
This commit is contained in:
parent
b12351a7eb
commit
f4176b0cf6
@ -23,14 +23,14 @@ use Symfony\Component\Messenger\Exception\TransportException;
|
||||
interface ReceiverInterface
|
||||
{
|
||||
/**
|
||||
* Receive some messages to the given handler.
|
||||
* Receives some messages to the given handler.
|
||||
*
|
||||
* While this method could return an unlimited number of messages,
|
||||
* the intention is that it returns only one, or a "small number"
|
||||
* of messages each time. This gives the user more flexibility:
|
||||
* they can finish processing the one (or "small number") of messages
|
||||
* from this receiver and move on to check other receivers for messages.
|
||||
* If a this method returns too many messages, it could cause a
|
||||
* If this method returns too many messages, it could cause a
|
||||
* blocking effect where handling the messages received from one
|
||||
* call to get() takes a long time, blocking other receivers from
|
||||
* being called.
|
||||
@ -46,7 +46,7 @@ interface ReceiverInterface
|
||||
public function get(): iterable;
|
||||
|
||||
/**
|
||||
* Acknowledge that the passed message was handled.
|
||||
* Acknowledges that the passed message was handled.
|
||||
*
|
||||
* @throws TransportException If there is an issue communicating with the transport
|
||||
*/
|
||||
|
@ -21,7 +21,7 @@ namespace Symfony\Component\Messenger;
|
||||
interface WorkerInterface
|
||||
{
|
||||
/**
|
||||
* Receive the messages and dispatch them to the bus.
|
||||
* Receives the messages and dispatch them to the bus.
|
||||
*
|
||||
* The $onHandledCallback will be passed the Envelope that was just
|
||||
* handled or null if nothing was handled.
|
||||
@ -31,7 +31,7 @@ interface WorkerInterface
|
||||
public function run(array $options = [], callable $onHandledCallback = null): void;
|
||||
|
||||
/**
|
||||
* Stop receiving messages.
|
||||
* Stops receiving messages.
|
||||
*/
|
||||
public function stop(): void;
|
||||
}
|
||||
|
Reference in New Issue
Block a user