aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/com/juick/service/activities
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/juick/service/activities')
-rw-r--r--src/main/java/com/juick/service/activities/ActivityListener.java6
-rw-r--r--src/main/java/com/juick/service/activities/AnnounceEvent.java22
-rw-r--r--src/main/java/com/juick/service/activities/UndoAnnounceEvent.java22
3 files changed, 50 insertions, 0 deletions
diff --git a/src/main/java/com/juick/service/activities/ActivityListener.java b/src/main/java/com/juick/service/activities/ActivityListener.java
index 863bda04..68e1d42a 100644
--- a/src/main/java/com/juick/service/activities/ActivityListener.java
+++ b/src/main/java/com/juick/service/activities/ActivityListener.java
@@ -16,4 +16,10 @@ public interface ActivityListener {
@Async
@EventListener
void deleteMessageEvent(DeleteMessageEvent event);
+ @Async
+ @EventListener
+ void processAnnounceEvent(AnnounceEvent event);
+ @Async
+ @EventListener
+ void undoAnnounceEvent(UndoAnnounceEvent event);
}
diff --git a/src/main/java/com/juick/service/activities/AnnounceEvent.java b/src/main/java/com/juick/service/activities/AnnounceEvent.java
new file mode 100644
index 00000000..00dbea8c
--- /dev/null
+++ b/src/main/java/com/juick/service/activities/AnnounceEvent.java
@@ -0,0 +1,22 @@
+package com.juick.service.activities;
+
+import org.springframework.context.ApplicationEvent;
+
+public class AnnounceEvent extends ApplicationEvent {
+ private String actorUri;
+ private String messageUri;
+
+ public AnnounceEvent(Object source, String actor, String messageUri) {
+ super(source);
+ this.actorUri = actor;
+ this.messageUri = messageUri;
+ }
+
+ public String getActorUri() {
+ return actorUri;
+ }
+
+ public String getMessageUri() {
+ return messageUri;
+ }
+}
diff --git a/src/main/java/com/juick/service/activities/UndoAnnounceEvent.java b/src/main/java/com/juick/service/activities/UndoAnnounceEvent.java
new file mode 100644
index 00000000..115f3146
--- /dev/null
+++ b/src/main/java/com/juick/service/activities/UndoAnnounceEvent.java
@@ -0,0 +1,22 @@
+package com.juick.service.activities;
+
+import org.springframework.context.ApplicationEvent;
+
+public class UndoAnnounceEvent extends ApplicationEvent {
+ private String actorUri;
+ private String messageUri;
+
+ public UndoAnnounceEvent(Object source, String actor, String messageUri) {
+ super(source);
+ this.actorUri = actor;
+ this.messageUri = messageUri;
+ }
+
+ public String getActorUri() {
+ return actorUri;
+ }
+
+ public String getMessageUri() {
+ return messageUri;
+ }
+}