usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mru...@apache.org
Subject usergrid git commit: Fix NPE for push notification processing.
Date Sat, 24 Feb 2018 19:44:20 GMT
Repository: usergrid
Updated Branches:
  refs/heads/master bd2385d76 -> 063595805


Fix NPE for push notification processing.


Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/06359580
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/06359580
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/06359580

Branch: refs/heads/master
Commit: 063595805cbf3efad6b961a9170bdf4953aa2e9d
Parents: bd2385d
Author: Michael Russo <russomichael@google.com>
Authored: Sat Feb 24 11:44:06 2018 -0800
Committer: Michael Russo <russomichael@google.com>
Committed: Sat Feb 24 11:44:06 2018 -0800

----------------------------------------------------------------------
 .../services/notifications/impl/ApplicationQueueManagerImpl.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/06359580/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
b/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
index b7afc2e..fcf63a8 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
@@ -356,11 +356,11 @@ public class ApplicationQueueManagerImpl implements ApplicationQueueManager
{
                             if(logger.isTraceEnabled()) {
                                 logger.trace("Queueing notification message for device: {}",
message.get().getDeviceId());
                             }
-                            qm.sendMessageToLocalRegion( message.get() , null );
+                            qm.sendMessageToLocalRegion( message.get(), Boolean.TRUE );
                             queueMeter.mark();
                         }
 
-                    } catch (IOException e) {
+                    } catch (Exception e) {
 
                         if(message.isPresent()){
                             logger.error("Unable to queue notification for notification UUID
{} and device UUID {} ",


Mime
View raw message