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 <[email protected]> Authored: Mon Nov 9 15:10:16 2015 -0700 Committer: Shawn Feldman <[email protected]> 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
