You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2018/02/24 19:44:20 UTC
usergrid git commit: Fix NPE for push notification processing.
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 <ru...@google.com>
Authored: Sat Feb 24 11:44:06 2018 -0800
Committer: Michael Russo <ru...@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 {} ",