You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2014/10/30 04:39:44 UTC
[18/45] git commit: log failure
log failure
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/bb25b5b3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/bb25b5b3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/bb25b5b3
Branch: refs/heads/key-row-sharding
Commit: bb25b5b38be755c4183b803189183ff953a712c1
Parents: 45d3ce4
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Oct 27 17:54:01 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Oct 27 17:54:01 2014 -0600
----------------------------------------------------------------------
.../usergrid/persistence/queue/impl/SQSQueueManagerImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/bb25b5b3/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 888370c..8c8ffff 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
@@ -207,7 +207,9 @@ public class SQSQueueManagerImpl implements QueueManager {
DeleteMessageBatchResult result = sqs.deleteMessageBatch(request);
boolean successful = result.getFailed().size() <= 0;
if(!successful){
- LOG.error("Commit failed {} messages", result.getFailed().size());
+ for( BatchResultErrorEntry failed : result.getFailed()) {
+ LOG.error("Commit failed reason: {} messages id: {}", failed.getMessage(),failed.getId());
+ }
}
}