Я новичок в инфраструктуре Akka и работаю над использованием записей из DistributedPubSubMediator. Изначально все работает нормально, я публикую sh запросы к topi c, которые выбирает Актер, подписавшийся на эту очередь. Но через некоторое время Актер перестает получать сообщения из очереди. Я не настраивал ни одно из свойств, может ли это быть из-за некоторых ограничений размера очереди?
Кто-нибудь сталкивался с подобной проблемой или знает, чего мне не хватает?