import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.ObjectMapper;
import de.juplo.kafka.chat.backend.domain.Message;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import de.juplo.kafka.chat.backend.domain.Message;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
{
Path path = chatroomsPath();
log.info("Writing chatrooms to {}", path);
{
Path path = chatroomsPath();
log.info("Writing chatrooms to {}", path);
generator.writeObject(chatroomTo);
writeMessages(chatroomTo, chatroom.getMessages());
}
generator.writeObject(chatroomTo);
writeMessages(chatroomTo, chatroom.getMessages());
}
- InMemoryChatroomService chatroomService =
- new InMemoryChatroomService(readMessages(chatroomTo));
- return chatroomFactory.restoreChatroom(
- chatroomTo.getId(),
- chatroomTo.getName(),
+ InMemoryChatRoomService chatroomService =
+ new InMemoryChatRoomService(readMessages(chatRoomTo));
+ return service.restoreChatroom(
+ chatRoomTo.getId(),
+ chatRoomTo.getName(),
{
Path path = chatroomPath(chatroomTo);
log.info("Writing messages for {} to {}", chatroomTo, path);
{
Path path = chatroomPath(chatroomTo);
log.info("Writing messages for {} to {}", chatroomTo, path);