From 000a99c53efd827a83c0e91ed9eb637d4fc049dc Mon Sep 17 00:00:00 2001 From: Athou Date: Sat, 30 Jan 2021 21:43:21 +0100 Subject: [PATCH] speed up tests --- .../com/commafeed/backend/feed/FeedRefreshUpdater.java | 8 ++++++++ .../com/commafeed/backend/service/PubSubService.java | 9 --------- 2 files changed, 8 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java b/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java index 07868fe3..b749f554 100644 --- a/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java +++ b/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java @@ -208,6 +208,14 @@ public class FeedRefreshUpdater implements Managed { new Thread() { @Override public void run() { + try { + // make sure the feed has been updated in the database so that the + // callback works + Thread.sleep(30000); + } catch (InterruptedException e1) { + // do nothing + } + pubSubService.subscribe(feed); } }.start(); diff --git a/src/main/java/com/commafeed/backend/service/PubSubService.java b/src/main/java/com/commafeed/backend/service/PubSubService.java index 148ead1c..708fa47b 100644 --- a/src/main/java/com/commafeed/backend/service/PubSubService.java +++ b/src/main/java/com/commafeed/backend/service/PubSubService.java @@ -41,15 +41,6 @@ public class PubSubService { private final FeedQueues queues; public void subscribe(Feed feed) { - - try { - // make sure the feed has been updated in the database so that the - // callback works - Thread.sleep(30000); - } catch (InterruptedException e1) { - // do nothing - } - String hub = feed.getPushHub(); String topic = feed.getPushTopic(); String publicUrl = FeedUtils.removeTrailingSlash(config.getApplicationSettings().getPublicUrl());