From 2e81736a2276948df44d292d055d71d4eb9fe654 Mon Sep 17 00:00:00 2001
From: Alexis Durgnat <alexis.durgnat@etu.hesge.ch>
Date: Sun, 3 Feb 2019 20:04:57 +0100
Subject: [PATCH] Meeting events
---
src/main/java/ch/hepia/mq/Message.java | 2 +-
src/main/java/ch/hepia/mq/MessageManager.java | 8 ++++++++
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git a/src/main/java/ch/hepia/mq/Message.java b/src/main/java/ch/hepia/mq/Message.java
index 20b0c81..6eb92eb 100644
--- a/src/main/java/ch/hepia/mq/Message.java
+++ b/src/main/java/ch/hepia/mq/Message.java
@@ -3,7 +3,7 @@ import java.io.Serializable;
public final class Message implements Serializable {
public static enum Type {
- JoinedJourney, LeftJourney, ChatMessage
+ JoinedJourney, LeftJourney, ChatMessage, Meeting
}
private static final long serialVersionUID = 0xAEF34565673L;
diff --git a/src/main/java/ch/hepia/mq/MessageManager.java b/src/main/java/ch/hepia/mq/MessageManager.java
index 1b57f6c..abb2b1b 100644
--- a/src/main/java/ch/hepia/mq/MessageManager.java
+++ b/src/main/java/ch/hepia/mq/MessageManager.java
@@ -80,6 +80,14 @@ public class MessageManager extends MessageQueue {
this.conditionalSubscribe(Message.Type.JoinedJourney, eventHandler, condition);
}
+ /**
+ * Subscribe to Meetings events
+ * @param eventHandler Meeting consumer
+ * @param condition Meeting predicate
+ */
+ public void conditionalSubscribeMeeting(Consumer<Meeting> eventHandler, Predicate<Meeting> condition) {
+ this.conditionalSubscribe(Message.Type.Meeting, eventHandler, condition);
+ }
/**
* Subscribe to LeftJourney events validating the condition
* @param eventHandler LeftJourney consumer
--
GitLab