You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2014/10/14 00:45:52 UTC
git commit: change queuename
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o c88282b08 -> 99495f94a
change queuename
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/99495f94
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/99495f94
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/99495f94
Branch: refs/heads/two-dot-o
Commit: 99495f94a443b92ce9578041c606b65b6f4eca54
Parents: c88282b
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Oct 13 16:45:34 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Oct 13 16:45:34 2014 -0600
----------------------------------------------------------------------
.../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/99495f94/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 cfeebf5..d0b2a77 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
@@ -141,7 +141,7 @@ public class QueueListener {
try {
svcMgr = smf.getServiceManager(smf.getManagementAppId());
LOG.info("getting from queue {} ", queueName);
- QueueScope queueScope = new QueueScopeImpl(new SimpleId(smf.getManagementAppId(),"notifications"),queueName);
+ QueueScope queueScope = new QueueScopeImpl(new SimpleId(smf.getManagementAppId(),"usergrid"),queueName);
QueueManager queueManager = TEST_QUEUE_MANAGER != null ? TEST_QUEUE_MANAGER : queueManagerFactory.getQueueManager(queueScope);
Timer.Context timerContext = timer.time();
List<QueueMessage> messages = queueManager.getMessages(getBatchSize(), MESSAGE_TRANSACTION_TIMEOUT, 5000, ApplicationQueueMessage.class);