apache/maven-mvnd
1
0
Fork 0
mirror of https://github.com/apache/maven-mvnd.git synced 2025-09-27 16:08:21 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Make sure all log events are displayed when an exception occurs in the daemon

Browse Source
This commit is contained in:
Guillaume Nodet
2020-10-07 15:22:17 +02:00
parent cd5425a80d
commit ba751ad869
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
client/src/main/java/org/jboss/fuse/mvnd/client/TerminalOutput.java
View File

@@ -15,7 +15,6 @@
*/
package org.jboss.fuse.mvnd.client;
import java.io.Flushable;
import java.io.IOException;
import java.io.InterruptedIOException;
import java.io.Writer;
@@ -40,8 +39,6 @@ import org.jline.utils.AttributedString;
import org.jline.utils.AttributedStringBuilder;
import org.jline.utils.AttributedStyle;
import org.jline.utils.Display;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* A terminal {@link ClientOutput} based on JLine.
@@ -52,8 +49,6 @@ public class TerminalOutput implements ClientOutput {
public static final int CTRL_M = 'M' & 0x1f;
private static final Logger LOGGER = LoggerFactory.getLogger(TerminalOutput.class);
private final BlockingQueue<Event> queue;
private final Terminal terminal;
private final Display display;
@@ -175,9 +170,7 @@ public class TerminalOutput implements ClientOutput {
case END_OF_STREAM: {
projects.values().stream().flatMap(p -> p.log.stream()).forEach(log);
clearDisplay();
LOGGER.debug("Done receiving, printing log");
log.close();
LOGGER.debug("Done !");
terminal.flush();
return;
}
@@ -193,8 +186,9 @@ public class TerminalOutput implements ClientOutput {
case ERROR: {
projects.values().stream().flatMap(p -> p.log.stream()).forEach(log);
clearDisplay();
log.close();
final AttributedStyle s = new AttributedStyle().bold().foreground(AttributedStyle.RED);
terminal.writer().println(new AttributedString(entry.message, s).toAnsi());
new AttributedString(entry.message, s).println(terminal);
terminal.flush();
return;
}
@@ -326,8 +320,13 @@ public class TerminalOutput implements ClientOutput {
/**
* A closeable string message consumer.
*/
interface ClientLog extends Consumer<String>, Flushable, AutoCloseable {
interface ClientLog extends Consumer<String> {
void accept(String message);
void flush() throws IOException;
void close() throws IOException;
}
/**