Module notedealer::activitypub::inbox_queue

source · [−]
Expand description

Delivers activities to inboxes asynchronously.

Functions

deliver 🔒
Delivers the given list of objects to the inboxes over HTTP.
delivery_loop
Runs the following loop until an interrupt signal is received: get currently sendable deliveries (Database::get_deliveries), if there’s none, wait for more (wait_for_deliveries), if there’s some, send them (deliver), wait for 100 ms, repeat.
wait_for_deliveries 🔒
Attempts to wait for deliveries accurately (Database::wait_for_inbox_delivery), and if it fails, falls back to printing the error and waiting a flat 10 seconds.