1 files changed, 5 insertions, 8 deletions
diff --git a/src/main/java/com/juick/service/SubscriptionServiceImpl.java b/src/main/java/com/juick/service/SubscriptionServiceImpl.java
index b8d32c6a..85980f1a 100644
--- a/src/main/java/com/juick/service/SubscriptionServiceImpl.java
+++ b/src/main/java/com/juick/service/SubscriptionServiceImpl.java
@@ -126,14 +126,11 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip
     @Transactional
     @Override
     public boolean subscribeMessage(final Message message, final User user) {
-        try {
-            boolean result = getJdbcTemplate().update(
-                    "INSERT INTO subscr_messages(suser_id, message_id) VALUES (?, ?)", user.getUid(), message.getMid()) == 1;
-            messagesService.setLastReadComment(user, message.getMid(), message.getReplies());
-            return result;
-        } catch (DuplicateKeyException e) {
-            return true;
-        }
+        boolean result = getJdbcTemplate().update(
+                "INSERT INTO subscr_messages(suser_id, message_id) VALUES (?, ?) ON DUPLICATE KEY UPDATE suser_id=?",
+                user.getUid(), message.getMid(), user.getUid()) == 1;
+        messagesService.setLastReadComment(user, message.getMid(), message.getReplies());
+        return result;
     }
 
     @Transactional