Use same timeout value as old queue implementation did
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/c08e02a9 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/c08e02a9 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/c08e02a9 Branch: refs/heads/master Commit: c08e02a914d98bd048f997cddd47b343ba9908c1 Parents: 727ff1d Author: Dave Johnson <[email protected]> Authored: Thu Sep 22 07:47:07 2016 -0400 Committer: Dave Johnson <[email protected]> Committed: Thu Sep 22 07:47:07 2016 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/usergrid/persistence/qakka/QakkaFig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/c08e02a9/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/QakkaFig.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/QakkaFig.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/QakkaFig.java index da47c98..472c241 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/QakkaFig.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/QakkaFig.java @@ -89,7 +89,7 @@ public interface QakkaFig extends GuicyFig, Serializable { /** Time for queue messages to timeout, if not set per queue */ @Key(QUEUE_TIMEOUT_SECONDS) - @Default("10") + @Default("30") int getQueueTimeoutSeconds(); /** How often to refresh each queue's in-memory data */
