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 2015/11/09 23:10:29 UTC
usergrid git commit: remove repeated logic
Repository: usergrid
Updated Branches:
refs/heads/jackson-exclusion d363242e5 -> e3d1f3b6d
remove repeated logic
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/e3d1f3b6
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/e3d1f3b6
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/e3d1f3b6
Branch: refs/heads/jackson-exclusion
Commit: e3d1f3b6d8c3be86f0d36dbf6c86321676860a34
Parents: d363242
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Nov 9 15:10:16 2015 -0700
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Nov 9 15:10:16 2015 -0700
----------------------------------------------------------------------
.../usergrid/persistence/queue/DefaultQueueManager.java | 7 +------
.../usergrid/services/notifications/wns/WNSAdapterTest.java | 2 +-
2 files changed, 2 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/e3d1f3b6/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
index c3b5917..ea30fc0 100644
--- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
+++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
@@ -74,12 +74,7 @@ public class DefaultQueueManager implements QueueManager {
@Override
public void sendMessages(List bodies) throws IOException {
for(Object body : bodies){
- String uuid = UUID.randomUUID().toString();
- try {
- queue.put(new QueueMessage(uuid, "handle_" + uuid, body, "put type here"));
- }catch (InterruptedException ie){
- throw new RuntimeException(ie);
- }
+ sendMessage( ( Serializable )body);
}
}
http://git-wip-us.apache.org/repos/asf/usergrid/blob/e3d1f3b6/stack/services/src/test/java/org/apache/usergrid/services/notifications/wns/WNSAdapterTest.java
----------------------------------------------------------------------
diff --git a/stack/services/src/test/java/org/apache/usergrid/services/notifications/wns/WNSAdapterTest.java b/stack/services/src/test/java/org/apache/usergrid/services/notifications/wns/WNSAdapterTest.java
index aa60e84..35f3180 100644
--- a/stack/services/src/test/java/org/apache/usergrid/services/notifications/wns/WNSAdapterTest.java
+++ b/stack/services/src/test/java/org/apache/usergrid/services/notifications/wns/WNSAdapterTest.java
@@ -30,7 +30,7 @@ import org.junit.Test;
import java.util.UUID;
/**
- * Classy class class.
+ * test windows phone.
*/
public class WNSAdapterTest extends AbstractServiceIT{
@Test