|
|
@@ -120,6 +120,30 @@ class TelegramBotHandler extends AbstractProcessingHandler
|
|
|
return $this;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * {@inheritdoc}
|
|
|
+ */
|
|
|
+ public function handleBatch(array $records): void
|
|
|
+ {
|
|
|
+ $messages = [];
|
|
|
+
|
|
|
+ foreach ($records as $record) {
|
|
|
+ if (!$this->isHandling($record)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($this->processors) {
|
|
|
+ $record = $this->processRecord($record);
|
|
|
+ }
|
|
|
+
|
|
|
+ $messages[] = $record;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!empty($messages)) {
|
|
|
+ $this->send((string) $this->getFormatter()->formatBatch($messages));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* @inheritDoc
|
|
|
*/
|