diff options
author | Vitaly Takmazov | 2016-07-21 14:22:03 +0300 |
---|---|---|
committer | Vitaly Takmazov | 2016-07-21 14:22:03 +0300 |
commit | 1a5a47dc89b576b3fd6e555b6196973d0d9e32c3 (patch) | |
tree | 45cc2d9c74a0c05635652f1e17d60f3f7ad23002 | |
parent | 477dc450dca99616fa335c155c4be9048a69deee (diff) |
JuickProtocol: subscribe to own message
-rw-r--r-- | juick-core/src/main/java/com/juick/server/protocol/JuickProtocol.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/juick-core/src/main/java/com/juick/server/protocol/JuickProtocol.java b/juick-core/src/main/java/com/juick/server/protocol/JuickProtocol.java index bb7615dd..f7056cd4 100644 --- a/juick-core/src/main/java/com/juick/server/protocol/JuickProtocol.java +++ b/juick-core/src/main/java/com/juick/server/protocol/JuickProtocol.java @@ -65,6 +65,7 @@ public class JuickProtocol { List<Tag> tags = TagQueries.fromString(sql, input, false); String body = input.substring(TagQueries.toString(tags).length()); int mid = MessagesQueries.createMessage(sql, user.getUID(), body, null, tags); + SubscriptionsQueries.subscribeMessage(sql, mid, user.getUID()); //app.events().publishEvent(new JuickMessageEvent(app.messages().getMessage(mid))); return new ProtocolReply("New message posted.\n#" + mid + " " + baseUri + mid, Optional.of(json.serializeList(Collections.singletonList(MessagesQueries.getMessage(sql, mid))))); |