feat: implemented a listen-method for the chat-service based on a Flux

[demos/kafka/chat] / mongodb / MessageRepository.java

package de.juplo.kafka.chat.backend.storage.mongodb;

import org.springframework.data.mongodb.repository.MongoRepository;

import java.util.List;


public interface MessageRepository extends MongoRepository<MessageTo, String>
{
  List<MessageTo> findByChatRoomIdOrderBySerialAsc(String chatRoomId);
}