Replace the "Queue" mechanism with deferred workers

diff --git a/diaspora/diaspora.php b/diaspora/diaspora.php
index 88630fe..d8c6343 100644 (file)
--- a/diaspora/diaspora.php
+++ b/diaspora/diaspora.php
@@ -18,6 +18,7 @@ use Friendica\Core\PConfig;
 use Friendica\Core\Protocol;
 use Friendica\Database\DBA;
 use Friendica\Model\Queue;
+use Friendica\Core\Worker;
 
 function diaspora_install()
 {
@@ -402,8 +403,8 @@ function diaspora_send(App $a, array &$b)
 
                        $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $body]);
 
-                       Queue::add($a->contact, Protocol::DIASPORA2, $s);
-                       notice(L10n::t('Diaspora post failed. Queued for retry.').EOL);
+                       Worker::defer();
+                       notice(L10n::t('Diaspora post failed. Deferred for retry.').EOL);
                }
        }
 }

diff --git a/pumpio/pumpio.php b/pumpio/pumpio.php
index 319c109..b6716eb 100644 (file)
--- a/pumpio/pumpio.php
+++ b/pumpio/pumpio.php
@@ -617,8 +617,8 @@ function pumpio_send(App $a, array &$b)
 
                        $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $params]);
 
-                       Queue::add($a->contact, Protocol::PUMPIO, $s);
-                       notice(L10n::t('Pump.io post failed. Queued for retry.').EOL);
+                       Worker::defer();
+                       notice(L10n::t('Pump.io post failed. Deferred for retry.').EOL);
                }
        }
 }
@@ -694,8 +694,8 @@ function pumpio_action(App $a, $uid, $uri, $action, $content = "")
 
                $s = serialize(['url' => $url, 'item' => $orig_post["id"], 'post' => $params]);
 
-               Queue::add($a->contact, Protocol::PUMPIO, $s);
-               notice(L10n::t('Pump.io like failed. Queued for retry.').EOL);
+               Worker::defer();
+               notice(L10n::t('Pump.io like failed. Deferred for retry.').EOL);
        }
 }
 

diff --git a/twitter/twitter.php b/twitter/twitter.php
index 2d331a7..74ebf5f 100644 (file)
--- a/twitter/twitter.php
+++ b/twitter/twitter.php
@@ -692,8 +692,8 @@ function twitter_post_hook(App $a, array &$b)
 
                        $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $post]);
 
-                       Queue::add($a->contact, Protocol::TWITTER, $s);
-                       notice(L10n::t('Twitter post failed. Queued for retry.') . EOL);
+                       Worker::defer();
+                       notice(L10n::t('Twitter post failed. Deferred for retry.') . EOL);
                } elseif ($iscomment) {
                        Logger::log('twitter_post: Update extid ' . $result->id_str . " for post id " . $b['id']);
                        Item::update(['extid' => "twitter::" . $result->id_str], ['id' => $b['id']]);