diff --git a/src/main/java/com/redhat/composer/services/ChatBotService.java b/src/main/java/com/redhat/composer/services/ChatBotService.java index 48103f7..249254d 100644 --- a/src/main/java/com/redhat/composer/services/ChatBotService.java +++ b/src/main/java/com/redhat/composer/services/ChatBotService.java @@ -96,11 +96,11 @@ public Multi chat(ChatBotRequest request) { .onNext(em::emit) .onRetrieved(sources -> { try { + em.emit("START_SOURCES_STRING\n"); em.emit(objectMapper.writeValueAsString(new ContentResponse(sources))); em.emit("\nEND_SOURCES_STRING\n"); } catch (JsonProcessingException e) { log.error("Sources not processable: %e", e); - e.printStackTrace(); } }) .onError(em::fail)