usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toddn...@apache.org
Subject [20/50] [abbrv] incubator-usergrid git commit: Changed default wait time to 10s
Date Thu, 28 May 2015 12:53:25 GMT
Changed default wait time to 10s


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/b4d8be67
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/b4d8be67
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/b4d8be67

Branch: refs/heads/USERGRID-669
Commit: b4d8be677fcf651845bfcdc41f153f41eb645639
Parents: e27d9f0
Author: Jeff West <jwest@apigee.com>
Authored: Tue May 26 09:04:53 2015 -0700
Committer: Jeff West <jwest@apigee.com>
Committed: Tue May 26 09:04:53 2015 -0700

----------------------------------------------------------------------
 .../org/apache/usergrid/services/notifications/QueueListener.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/b4d8be67/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
index e45b82a..e9f64b4 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
@@ -156,7 +156,7 @@ public class QueueListener  {
             try {
 
                 Timer.Context timerContext = timer.time();
-                List<QueueMessage> messages = queueManager.getMessages(getBatchSize(),
MESSAGE_TRANSACTION_TIMEOUT, 5000, ApplicationQueueMessage.class);
+                List<QueueMessage> messages = queueManager.getMessages(getBatchSize(),
MESSAGE_TRANSACTION_TIMEOUT, 10000, ApplicationQueueMessage.class);
                 LOG.info("retrieved batch of {} messages from queue {} ", messages.size(),queueName);
 
                 if (messages.size() > 0) {


Mime
View raw message