//package org.egl_cepgl.pm.repository;
//
//import org.bson.types.ObjectId;
//import org.egl_cepgl.pm.model.ChatInbox;
//import org.egl_cepgl.pm.model.ChatMessage;
//import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
//import org.springframework.data.mongodb.repository.Tailable;
//import org.springframework.stereotype.Repository;
//import reactor.core.publisher.Flux;
//import reactor.core.publisher.Mono;
//
//@Repository
//public interface ChatMessageRepository extends ReactiveMongoRepository<ChatMessage, String>
//{
//    @Tailable
//    Flux<ChatMessage> findAllBy();
//
//    @Tailable
//    Flux<ChatMessage> findAllByIndBoxId(String inbox);
//}