usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toddn...@apache.org
Subject [2/2] usergrid git commit: Added error handling.
Date Mon, 31 Aug 2015 20:23:36 GMT
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 <michaelarusso@gmail.com>
Authored: Mon Aug 31 13:10:04 2015 -0700
Committer: Michael Russo <michaelarusso@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();
 
     }


Mime
View raw message