You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2014/10/29 20:21:46 UTC
[05/22] git commit: fix failure sqs message
fix failure sqs message
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/99078639
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/99078639
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/99078639
Branch: refs/heads/two-dot-o-events
Commit: 990786392acf9818cfaf09cf649cea8053279945
Parents: e30a7b3
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Oct 27 15:27:07 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Oct 27 15:27:07 2014 -0600
----------------------------------------------------------------------
.../usergrid/persistence/queue/impl/SQSQueueManagerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/99078639/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 313b4d7..888370c 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
@@ -205,7 +205,7 @@ public class SQSQueueManagerImpl implements QueueManager {
}
DeleteMessageBatchRequest request = new DeleteMessageBatchRequest(url,entries);
DeleteMessageBatchResult result = sqs.deleteMessageBatch(request);
- boolean successful = result.getFailed().size() > 0;
+ boolean successful = result.getFailed().size() <= 0;
if(!successful){
LOG.error("Commit failed {} messages", result.getFailed().size());
}