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 19:34:49 UTC
git commit: change queue name
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o f5452af6a -> 27db106eb
change queue name
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/27db106e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/27db106e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/27db106e
Branch: refs/heads/two-dot-o
Commit: 27db106eb1668d89d401ab705920749a69826fba
Parents: f5452af
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Oct 14 11:34:32 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Oct 14 11:34:32 2014 -0600
----------------------------------------------------------------------
.../usergrid/persistence/queue/impl/SQSQueueManagerImpl.java | 2 +-
.../usergrid/services/notifications/ApplicationQueueManager.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/27db106e/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SQSQueueManagerImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SQSQueueManagerImpl.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SQSQueueManagerImpl.java
index ee45b25..4b86a52 100644
--- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SQSQueueManagerImpl.java
+++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SQSQueueManagerImpl.java
@@ -82,7 +82,7 @@ public class SQSQueueManagerImpl implements QueueManager {
}
private String getName() {
- String name = scope.getApplication().getType() + scope.getApplication().getUuid().toString() + scope.getName();
+ String name = scope.getApplication().getType() + "_"+ scope.getName() + "_"+ scope.getApplication().getUuid().toString();
return name;
}
public Queue getQueue(){
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/27db106e/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java b/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
index 00f3f5e..e819356 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
@@ -46,7 +46,7 @@ import java.util.concurrent.atomic.AtomicInteger;
public class ApplicationQueueManager {
- public static String DEFAULT_QUEUE_NAME = "queuelistenerv1_60";
+ public static String DEFAULT_QUEUE_NAME = "push_v1";
public static final String DEFAULT_QUEUE_PROPERTY = "usergrid.notifications.listener.queue";
private static final Logger LOG = LoggerFactory.getLogger(ApplicationQueueManager.class);