diff options
| -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))))); |