diff options
Diffstat (limited to 'Omni/Agent/Telegram/IncomingQueue.hs')
| -rw-r--r-- | Omni/Agent/Telegram/IncomingQueue.hs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/Omni/Agent/Telegram/IncomingQueue.hs b/Omni/Agent/Telegram/IncomingQueue.hs index 875fbf3..60864ed 100644 --- a/Omni/Agent/Telegram/IncomingQueue.hs +++ b/Omni/Agent/Telegram/IncomingQueue.hs @@ -178,7 +178,10 @@ startIncomingBatcher queuesVar processFn = (firstQm : _) -> do let baseMsg = qmMsg firstQm batchedTxt = formatBatch qmsgs - processFn baseMsg batchedTxt + result <- try @SomeException (processFn baseMsg batchedTxt) + case result of + Left err -> putText <| "Batcher error processing message: " <> tshow err + Right () -> pure () threadDelay 200000 formatBatch :: [QueuedMsg] -> Text |