From 642c78093674219b5a56207c10081861fdb655b5 Mon Sep 17 00:00:00 2001 From: Athou Date: Sun, 21 Jul 2013 11:13:26 +0200 Subject: [PATCH] rename queues --- .../java/com/commafeed/backend/feeds/FeedRefreshUpdater.java | 2 +- .../java/com/commafeed/backend/feeds/FeedRefreshWorker.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java index ec21e7ee..7450a619 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java @@ -73,7 +73,7 @@ public class FeedRefreshUpdater { ApplicationSettings settings = applicationSettingsService.get(); int threads = Math.max(settings.getDatabaseUpdateThreads(), 1); log.info("Creating database pool with {} threads", threads); - pool = new FeedRefreshExecutor("FeedRefreshUpdater", threads, 500 * threads); + pool = new FeedRefreshExecutor("feed-refresh-updater", threads, 500 * threads); locks = Striped.lazyWeakLock(threads * 100000); } diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java index d67c1639..a5393d9f 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java @@ -53,7 +53,7 @@ public class FeedRefreshWorker { ApplicationSettings settings = applicationSettingsService.get(); int threads = settings.getBackgroundThreads(); log.info("Creating refresh worker pool with {} threads", threads); - pool = new FeedRefreshExecutor("FeedRefreshUpdater", threads, + pool = new FeedRefreshExecutor("feed-refresh-worker", threads, 20 * threads); }