ChatMessage

src/main/java/ch/hepia/Main.java

 package ch.hepia;
 
 import ch.hepia.config.AppConfig;
-import ch.hepia.events.JoinedJourney;
+import ch.hepia.events.*;
 import ch.hepia.models.User;
 import ch.hepia.mq.MessageManager;
 import javafx.application.Application;
@@ -28,6 +28,8 @@ public class Main extends Application {
 				AppConfig.RABBITMQ_HOSTNAME, "frog", "poney1234", "broadcaster");
 		m.sendJoinedJourney(new JoinedJourney(new User("Théo"), new ArrayList<>()));
 		m.subscribeJoinedJourney(joinedJourney -> System.out.println("When I was hungary"));
+		m.subscribeChatMessage(chatMessage -> System.out.println(chatMessage.getUser().toString() + ": " + chatMessage.getMessage()));
+		m.sendChatMessage(new ChatMessage(new User("Alexis"), "Bonjour le monde !"));
 		//launch(args);
 	}
 

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
+        JoinedJourney, LeftJourney, ChatMessage
     }
     
     private static final long serialVersionUID = 0xAEF34565673L;

src/main/java/ch/hepia/mq/MessageManager.java

@@ -66,4 +66,17 @@ public class MessageManager extends MessageQueue {
     public void sendLeftJourney(LeftJourney event) {
         this.sendEvent(Message.Type.LeftJourney, event);
     }
+
+
+    public void subscribeChatMessage(Consumer<ChatMessage> eventHandler) {
+        this.conditionalSubscribeChatMessage(eventHandler, (event) -> true);
+    }
+
+    public void conditionalSubscribeChatMessage(Consumer<ChatMessage> eventHandler, Predicate<ChatMessage> condition) {
+        this.conditionalSubscribe(Message.Type.ChatMessage, eventHandler, condition);
+    }
+
+    public void sendChatMessage(ChatMessage event) {
+        this.sendEvent(Message.Type.ChatMessage, event);
+    }
 }
\ No newline at end of file