Перая версия слушателя событий

Научил программу работать в двух потоках. Первый поток слушает все сообещния от сервера и записывает их в отдельный класс. Другой поток раз в какое-то время обращается к этому классу и что-то делает

src/main/java/org/sadtech/consultant/entity/Message.java

@@ -0,0 +1,18 @@
+package org.sadtech.consultant.entity;
+
+import lombok.Data;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+
+@Data
+@Entity
+public class Message {
+
+    @Id
+    private Long idMess;
+    private Long idUser;
+    private String text;
+
+
+}

src/main/java/org/sadtech/consultant/repository/MessageRepository.java

@@ -0,0 +1,8 @@
+package org.sadtech.consultant.repository;
+
+import org.sadtech.consultant.entity.Message;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface MessageRepository extends JpaRepository<Message, Long> {
+
+}

src/main/java/org/sadtech/consultant/service/MessageService.java

@@ -0,0 +1,8 @@
+package org.sadtech.consultant.service;
+
+import org.sadtech.consultant.entity.Message;
+
+public interface MessageService {
+
+    void addMessage(Message message);
+}

src/main/java/org/sadtech/consultant/service/impl/MessageServiceImpl.java

@@ -0,0 +1,16 @@
+package org.sadtech.consultant.service.impl;
+
+import org.sadtech.consultant.entity.Message;
+import org.sadtech.consultant.repository.MessageRepository;
+import org.sadtech.consultant.service.MessageService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class MessageServiceImpl implements MessageService {
+
+    @Autowired
+    private MessageRepository repository;
+
+    public void addMessage(Message message) {
+        repository.saveAndFlush(message);
+    }
+}