Class LimitConsumedMessagesExtension
一个消费者扩展，用于限制处理的消息数量。
这是一个占位符，直到上游 enqueue 项目扩展被合并。
属性摘要
-
$messageConsumed protected
int -
$messageLimit protected
int
方法摘要
-
__construct() public
-
onPostConsume() public
该方法在 SubscriptionConsumer::consume 方法退出后调用。此时消费可能会被中断。
-
onPreConsume() public
在每次新循环开始时执行，在调用 SubscriptionConsumer::consume 方法之前。在这一步，消费可能会被中断。
-
shouldBeStopped() protected
检查消费者是否应该停止。
方法详情
onPostConsume() ¶ public
onPostConsume(PostConsume $context): void该方法在 SubscriptionConsumer::consume 方法退出后调用。此时消费可能会被中断。
参数
-
PostConsume$context PostConsume 上下文。
返回
voidonPreConsume() ¶ public
onPreConsume(PreConsume $context): void在每次新循环开始时执行，在调用 SubscriptionConsumer::consume 方法之前。在这一步，消费可能会被中断。
参数
-
PreConsume$context PreConsume 上下文。
返回
voidshouldBeStopped() ¶ protected
shouldBeStopped(Psr\Log\LoggerInterface $logger): bool检查消费者是否应该停止。
参数
-
Psr\Log\LoggerInterface$logger 记录消息的日志记录器。
返回
bool