aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--juick-core/src/main/java/com/juick/server/protocol/JuickProtocol.java1
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)))));