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 2015/08/31 22:23:36 UTC
[2/2] usergrid git commit: Added error handling.
Added error handling.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/c905ebeb
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/c905ebeb
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/c905ebeb
Branch: refs/heads/two-dot-o-dev
Commit: c905ebebd366cc25b55ca6282d64111a2e8a9716
Parents: 405559a
Author: Michael Russo <mi...@gmail.com>
Authored: Mon Aug 31 13:10:04 2015 -0700
Committer: Michael Russo <mi...@gmail.com>
Committed: Mon Aug 31 13:10:04 2015 -0700
----------------------------------------------------------------------
.../usergrid/persistence/queue/impl/SNSQueueManagerImpl.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/c905ebeb/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java
index 8bfab8e..bcf4499 100644
--- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java
+++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/SNSQueueManagerImpl.java
@@ -424,6 +424,8 @@ public class SNSQueueManagerImpl implements QueueManager {
logger.error("Unable to convert queue object to a string message body", e);
}
+ }).doOnError(e ->{
+ logger.error("Error while publishing SNS message: ", e);
}).subscribeOn(rxTaskScheduler.getAsyncIOScheduler() ).subscribe();
}