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/07 18:03:08 UTC
[2/5] git commit: testqueue
testqueue
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/cc888f3a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/cc888f3a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/cc888f3a
Branch: refs/heads/two-dot-o
Commit: cc888f3aa92cbe9cad023a9b33d401fb4bfb4792
Parents: 5461e88
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Oct 7 09:53:18 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Oct 7 09:53:18 2014 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/services/TestQueueManager.java | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/cc888f3a/stack/services/src/test/java/org/apache/usergrid/services/TestQueueManager.java
----------------------------------------------------------------------
diff --git a/stack/services/src/test/java/org/apache/usergrid/services/TestQueueManager.java b/stack/services/src/test/java/org/apache/usergrid/services/TestQueueManager.java
index 9ae4f76..2df2c45 100644
--- a/stack/services/src/test/java/org/apache/usergrid/services/TestQueueManager.java
+++ b/stack/services/src/test/java/org/apache/usergrid/services/TestQueueManager.java
@@ -7,18 +7,19 @@ import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
+import java.util.concurrent.ConcurrentLinkedQueue;
/**
* Created by ApigeeCorporation on 10/7/14.
*/
public class TestQueueManager implements QueueManager {
- public List<QueueMessage> queue = new ArrayList<>();
+ public ConcurrentLinkedQueue<QueueMessage> queue = new ConcurrentLinkedQueue<>();
@Override
- public List<QueueMessage> getMessages(int limit, int transactionTimeout, int waitTime, Class klass) {
+ public synchronized List<QueueMessage> getMessages(int limit, int transactionTimeout, int waitTime, Class klass) {
List<QueueMessage> returnQueue = new ArrayList<>();
for(int i=0;i<limit;i++){
if(!queue.isEmpty()){
- returnQueue.add( queue.remove(0));
+ returnQueue.add( queue.remove());
}else{
break;
}
@@ -35,7 +36,7 @@ public class TestQueueManager implements QueueManager {
}
@Override
- public void sendMessages(List bodies) throws IOException {
+ public synchronized void sendMessages(List bodies) throws IOException {
for(Object body : bodies){
String uuid = UUID.randomUUID().toString();
queue.add(new QueueMessage(uuid,"handle_"+uuid,body));
@@ -43,7 +44,7 @@ public class TestQueueManager implements QueueManager {
}
@Override
- public void sendMessage(Object body) throws IOException {
+ public synchronized void sendMessage(Object body) throws IOException {
String uuid = UUID.randomUUID().toString();
queue.add(new QueueMessage(uuid,"handle_"+uuid,body));
}