while(true)
    {
        const savedMsgId = readVariable("latestMsgId").to!int;
        auto incoming = connection.getUpdates(savedMsgId, 30);

        foreach(ref inc; incoming)
        {
            saveProcessedMessageId(inc.update_id + 1);

            if(inc.chatId == -1)
                continue;

            auto chat = createChat(inc);

            if(!inc.message.isNull)
                upsertSubscriber(inc.message.chat.id, inc.message.from);

            try
                chat.dispatch();
            catch(TelegramBotApiException ex)
            {
                logError("TelegramBotApiException: "~ex.msg);
            }
        }

        destroy(incoming);

        //~ yield();
    }