diff --git a/src/main/java/ch/hepia/mq/Message.java b/src/main/java/ch/hepia/mq/Message.java
index 20b0c81c40891c4d8371070c505cc037f1288b7a..6eb92ebeac15dcdbbe829f403f8309ef7dd86f61 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 1b57f6ce76a11011c5399b54876fe5f14ea80992..abb2b1b378d8d8d67a6d066ea41ee229b1ece724 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