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 <russomich...@google.com> Authored: Sat Feb 24 11:44:06 2018 -0800 Committer: Michael Russo <russomich...@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 {} ",
