1 files changed, 4 insertions, 5 deletions
diff --git a/juick-server/src/main/java/com/juick/server/MessengerManager.java b/juick-server/src/main/java/com/juick/server/MessengerManager.java
index 14a43d6a..1fe04aca 100644
--- a/juick-server/src/main/java/com/juick/server/MessengerManager.java
+++ b/juick-server/src/main/java/com/juick/server/MessengerManager.java
@@ -112,12 +112,11 @@ public class MessengerManager implements ApplicationListener<MessageEvent> {
                     .forEach(user -> messengerService.getSenderId(user)
                             .ifPresent(t -> messengerNotify(t, subject, formatUrl(msg))));
         } else if (msg.getRid() > 0) {
-            // get quote
-            com.juick.Message jmsg = messagesService.getReply(msg.getMid(), msg.getRid());
-            String subject = formatPost(jmsg);
-            subscriptionService.getUsersSubscribedToComments(msg.getMid(), msg.getUser().getUid())
+            Message op = messagesService.getMessage(msg.getMid());
+            String subject = formatPost(msg);
+            subscriptionService.getUsersSubscribedToComments(op, msg)
                     .forEach(user -> messengerService.getSenderId(user)
-                            .ifPresent(t -> messengerNotify(t, subject, formatUrl(jmsg))));
+                            .ifPresent(t -> messengerNotify(t, subject, formatUrl(msg))));
         }
     }