[maven-release-plugin] prepare release gclc-socket-1.1.2

Signed-off-by: Emmanuel Bigeon <emmanuel@bigeon.fr>

gclc-socket/pom.xml

@@ -70,7 +70,7 @@ of Emmanuel Bigeon.                                                   -->
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <artifactId>gclc-socket</artifactId>
-  <version>1.1.0-SNAPSHOT</version>
+  <version>1.1.2</version>
   <packaging>jar</packaging>
   <url>http://www.bigeon.fr/emmanuel</url>
   <properties>
@@ -87,7 +87,7 @@ of Emmanuel Bigeon.                                                   -->
     <dependency>
     	<groupId>fr.bigeon</groupId>
     	<artifactId>gclc</artifactId>
-    	<version>1.3.1-SNAPSHOT</version>
+    	<version>1.3.2</version>
     </dependency>
     <dependency>
     	<groupId>fr.bigeon</groupId>
@@ -104,6 +104,6 @@ of Emmanuel Bigeon.                                                   -->
   <description>Socket implementation of GCLC</description>
   <scm>
     <developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
-    <tag>HEAD</tag>
+    <tag>gclc-socket-1.1.2</tag>
   </scm>
 </project>

gclc-socket/src/main/java/fr/bigeon/gclc/socket/ConsoleRunnable.java

@@ -48,14 +48,18 @@ import fr.bigeon.gclc.ConsoleApplication;
  * @author Emmanuel Bigeon */
 public class ConsoleRunnable implements Runnable {
 
+    /** The wait timeout */
     private static final long TIMEOUT = 100;
+    /** The logger */
     private static final Logger LOGGER = Logger
             .getLogger(ConsoleRunnable.class.getName());
     /** The actual application */
     private final ConsoleApplication app;
+    /** The synchro object */
     private final Object lock = new Object();
     /** the state of this runnable */
     private boolean running = true;
+    /** If a start is required */
     private boolean startReq;
 
     /** @param app the application */
@@ -75,7 +79,7 @@ public class ConsoleRunnable implements Runnable {
                         lock.wait(TIMEOUT);
                     } catch (InterruptedException e) {
                         LOGGER.log(Level.SEVERE,
-                                "Console application runnable interrupted wildly!",
+                                "Console application runnable interrupted wildly!", //$NON-NLS-1$
                                 e);
                         return;
                     }
@@ -114,6 +118,7 @@ public class ConsoleRunnable implements Runnable {
         }
     }
 
+    /** Request a restart of application */
     public void restart() {
         synchronized (lock) {
             startReq = true;
@@ -121,7 +126,7 @@ public class ConsoleRunnable implements Runnable {
             try {
                 lock.wait(TIMEOUT);
             } catch (InterruptedException e) {
-                LOGGER.log(Level.SEVERE, "Restart wait interrupted!", e);
+                LOGGER.log(Level.SEVERE, "Restart wait interrupted!", e); //$NON-NLS-1$
             }
         }
     }

gclc-socket/src/main/java/fr/bigeon/gclc/socket/SocketConsoleApplicationShell.java

@@ -35,18 +35,14 @@
 package fr.bigeon.gclc.socket;
 
 import java.io.BufferedReader;
-import java.io.BufferedWriter;
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.OutputStreamWriter;
-import java.io.PipedInputStream;
-import java.io.PipedOutputStream;
 import java.io.PrintWriter;
 import java.net.ServerSocket;
 import java.net.Socket;
 import java.net.SocketException;
 import java.nio.charset.Charset;
-import java.util.Arrays;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -54,7 +50,6 @@ import fr.bigeon.gclc.ConsoleApplication;
 import fr.bigeon.gclc.manager.ConsoleManager;
 import fr.bigeon.gclc.manager.PipedConsoleManager;
 import fr.bigeon.gclc.manager.ReadingRunnable;
-import fr.bigeon.smu.StringEncoder;
 
 /** This is a socket communicating console consoleManager
  * <p>
@@ -74,26 +69,60 @@ import fr.bigeon.smu.StringEncoder;
  * end of the execution.
  *
  * @author Emmanuel Bigeon */
-public class SocketConsoleApplicationShell implements Runnable {
+public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
+
+    /** The runnable to forward output of application to socket.
+     *
+     * @author Emmanuel Bigeon */
+    private final class OutputForwardRunnable implements Runnable {
+        /**
+         * 
+         */
+        private final PrintWriter writer;
+        /**
+         * 
+         */
+        private final Socket socket;
+
+        /** @param writer the writer
+         * @param socket the socket */
+        protected OutputForwardRunnable(PrintWriter writer, Socket socket) {
+            this.writer = writer;
+            this.socket = socket;
+        }
+
+        @SuppressWarnings("synthetic-access")
+        @Override
+        public void run() {
+            try {
+                while (!socket.isOutputShutdown()) {
+                    while (!socket.isOutputShutdown() &&
+                           !consoleManager.available()) {
+                        waitASec();
+                    }
+                    if (socket.isOutputShutdown()) {
+                        return;
+                    }
+                    String m = consoleManager.readNextLine();
+                    writer.println(m);
+                }
+            } catch (IOException e) {
+                LOGGER.log(Level.SEVERE, "Unexpected problem in manager", //$NON-NLS-1$
+                        e);
+            }
+        }
+
+    }
 
-    /**
-     * 
-     */
-    private static final String INTERRUPTION_WHILE_WORKING = "Interruption while application was working"; //$NON-NLS-1$
     /** The end of line character */
     protected static final String EOL = "\n"; //$NON-NLS-1$
-    /** The encoder */
-    private static final StringEncoder ENCODER = new StringEncoder("%", //$NON-NLS-1$
-            Arrays.asList(EOL));
     /** The class logger */
     private static final Logger LOGGER = Logger
             .getLogger(SocketConsoleApplicationShell.class.getName());
+    /** Time of wait */
     protected static final long ONE_TENTH_OF_SECOND = 100;
-    private static final long ONE_SEC = 100;
     /** The listening port */
     private final int port;
-    /** The input */
-    private final PipedInputStream consoleInput = new PipedInputStream();
     /** The application */
     private ConsoleApplication app;
     /** The session closing command */
@@ -101,9 +130,6 @@ public class SocketConsoleApplicationShell implements Runnable {
     /** The running status */
     private boolean running;
 
-//    /** The console manager implementation */
-//    private final ThreadedServerConsoleManager consoleManager = new ThreadedServerConsoleManager(
-//            ENCODER, promptingLock);
     /** The console manager implementation */
     private final PipedConsoleManager consoleManager;
     /** The auto close flag. if this is true, every request closes the session
@@ -164,38 +190,20 @@ public class SocketConsoleApplicationShell implements Runnable {
             this.serverSocket = actualServerSocket;
             running = true;
             // Create the streams
-            try (PipedOutputStream outStream = new PipedOutputStream();
-                 BufferedWriter writer = new BufferedWriter(
-                         new OutputStreamWriter(outStream, charset));
-                 InputStreamReader isr = new InputStreamReader(consoleInput,
-                         charset);
-                 BufferedReader inBuf = new BufferedReader(isr)) {
-                consoleInput.connect(outStream);
-//                consoleManager.setInput(inBuf);
-                runSokectServer(writer);
-                // Close the application
-                // Pass command to application
-                if (app.isRunning()) {
-                    writer.write(applicationShutdown + EOL);
-                    writer.flush();
-                }
-            }
-        } catch (
-
-        final IOException e) {
+            runSokectServer();
+        } catch (final IOException e) {
             LOGGER.log(Level.SEVERE,
                     "Communication error between client and server", e); //$NON-NLS-1$
         }
     }
 
-    /** @param writer the writer to the application
-     * @throws IOException if the communication with the client failed */
-    private void runSokectServer(BufferedWriter writer) throws IOException {
+    /** @throws IOException if the communication with the client failed */
+    private void runSokectServer() throws IOException {
         final ConsoleRunnable runnable = new ConsoleRunnable(app);
-        Thread appThNext = new Thread(runnable, "gclc-ctrl");
+        Thread appThNext = new Thread(runnable, "gclc-ctrl"); //$NON-NLS-1$
         appThNext.start();
         while (running) {
-            LOGGER.info("Opening client"); //$NON-NLS-1$
+            LOGGER.info("Waiting client"); //$NON-NLS-1$
             try (Socket clientSocket = serverSocket.accept();
                  PrintWriter out = new PrintWriter(new OutputStreamWriter(
                          clientSocket.getOutputStream(), charset), true);
@@ -204,21 +212,14 @@ public class SocketConsoleApplicationShell implements Runnable {
                  BufferedReader in = new BufferedReader(isr);) {
                 // this is not threaded to avoid several clients at the same
                 // time
+                LOGGER.info("Opening client"); //$NON-NLS-1$
 
                 // Initiate application
                 if (!runnable.isApplicationRunning()) {
-                    LOGGER.info("Start application");
-                    runnable.restart();
-                    synchronized (this) {
-                        try {
-                            wait(ONE_SEC);
-                        } catch (InterruptedException e) {
-                            LOGGER.log(Level.SEVERE,
-                                    "Interruption in application start", e);
-                        }
-                    }
+                    LOGGER.info("Start application"); //$NON-NLS-1$
+                    startApplication(runnable);
                 } else {
-                    LOGGER.info("Reconnect to application");
+                    LOGGER.info("Reconnect to application"); //$NON-NLS-1$
                     out.println("Reconnected"); //$NON-NLS-1$
                     out.println(consoleManager.getPrompt());
                 }
@@ -233,120 +234,99 @@ public class SocketConsoleApplicationShell implements Runnable {
         }
         runnable.setRunning(false);
         consoleManager.type(applicationShutdown);
-        LOGGER.info("Out client"); //$NON-NLS-1$
+        consoleManager.close();
+        LOGGER.info("Closing Server"); //$NON-NLS-1$
+    }
+
+    /** @param runnable the runnable */
+    private void startApplication(ConsoleRunnable runnable) {
+        runnable.restart();
+        synchronized (this) {
+            try {
+                wait(ONE_TENTH_OF_SECOND);
+            } catch (InterruptedException e) {
+                LOGGER.log(Level.SEVERE, "Interruption in application start", //$NON-NLS-1$
+                        e);
+            }
+        }
     }
 
     /** active communication between server and client
      * 
+     * @param socket the socket
      * @param writer the writer to the application
      * @param in the input from the client
      * @throws IOException if the communication failed */
     private void communicate(final Socket socket, final PrintWriter writer,
                              BufferedReader in) throws IOException {
-        Thread th = new Thread(new Runnable() {
-
-            @SuppressWarnings("synthetic-access")
-            @Override
-            public void run() {
-                try {
-                    while (!socket.isOutputShutdown()) {
-                        while (!socket.isOutputShutdown() &&
-                               !consoleManager.available()) {
-                            try {
-                                synchronized (this) {
-                                    wait(ONE_TENTH_OF_SECOND);
-                                }
-                            } catch (InterruptedException e) {
-                                LOGGER.log(Level.SEVERE, "Interrupted wait", //$NON-NLS-1$
-                                        e);
-                                return;
-                            }
-                        }
-                        if (socket.isOutputShutdown()) {
-                            return;
-                        }
-                        String m = consoleManager.readNextLine();
-                        writer.println(m);
-                    }
-                } catch (IOException e) {
-                    LOGGER.log(Level.SEVERE, "Unexpected problem in manager", //$NON-NLS-1$
-                            e);
-                }
-            }
-        }, "ClientComm"); //$NON-NLS-1$
+        Thread th = new Thread(new OutputForwardRunnable(writer, socket),
+                "ClientComm"); //$NON-NLS-1$
         th.start();
         if (autoClose) {
             communicateOnce(socket, in);
         } else {
             communicateLoop(socket, in);
+
         }
     }
 
-    /** @param in the input from the client
+    /** @param socket the socket
+     * @param in the input from the client
      * @throws IOException if the communication failed */
     private void communicateOnce(Socket socket,
                                  BufferedReader in) throws IOException {
         ReadingRunnable reading = new ReadingRunnable(in);
-        Thread th = new Thread(reading, "gclcToApp");
+        Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
         th.start();
-        String ln;
-        if (app.isRunning()) {
-            while (app.isRunning() && !reading.hasMessage()) {
-                synchronized (this) {
-                    try {
-                        wait(ONE_SEC);
-                    } catch (InterruptedException e) {
-                        LOGGER.log(Level.SEVERE, "Wait interrupted", e);
-                    }
-                }
-            }
-            if (!app.isRunning()) {
-                return;
-            }
-            ln = reading.getMessage();
-            if (ln.equals(close)) {
-                return;
-            }
-            // Pass command to application
-            consoleManager.type(ln);
-        }
+        communicationContent(reading);
         reading.setRunning(false);
         socket.shutdownOutput();
     }
 
-    /** @param in the input from the client
+    /** @param socket the socket
+     * @param in the input from the client
      * @throws IOException if the communication failed */
     private void communicateLoop(Socket socket,
                                  BufferedReader in) throws IOException {
         ReadingRunnable reading = new ReadingRunnable(in);
-        Thread th = new Thread(reading, "gclcToApp");
+        Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
         th.start();
-        String ln;
-        while (app.isRunning()) {
-            while (app.isRunning() && !reading.hasMessage()) {
-                synchronized (this) {
-                    try {
-                        wait(ONE_SEC);
-                    } catch (InterruptedException e) {
-                        LOGGER.log(Level.SEVERE, "Wait interrupted", e);
-                    }
-                }
-            }
-            if (!app.isRunning()) {
-                break;
-            }
-            ln = reading.getMessage();
-            if (ln.equals(close)) {
-                break;
-            }
-            // Pass command to application
-            consoleManager.type(ln);
+        while (app.isRunning() && communicationContent(reading)) {
+            // keep on going
         }
         reading.setRunning(false);
         socket.shutdownOutput();
 
     }
 
+    /** @param reading the reading
+     * @return if the communication should be stopped.
+     * @throws IOException if the reading failed */
+    private boolean communicationContent(ReadingRunnable reading) throws IOException {
+        try {
+            while (app.isRunning() && !reading.hasMessage()) {
+                synchronized (this) {
+                    waitASec();
+                }
+            }
+        } catch (IOException e) {
+            LOGGER.warning("Client seems dead. Closing communication"); //$NON-NLS-1$
+            LOGGER.log(Level.FINE, "Wait on message from client failed", e); //$NON-NLS-1$
+            return false;
+        }
+        if (!app.isRunning()) {
+            return false;
+        }
+        String ln = reading.getMessage();
+        if (ln.equals(close)) {
+            consoleManager.println("Bye."); //$NON-NLS-1$
+            return false;
+        }
+        // Pass command to application
+        consoleManager.type(ln);
+        return true;
+    }
+
     /** @return the consoleManager */
     public synchronized ConsoleManager getConsoleManager() {
         return consoleManager;
@@ -371,4 +351,23 @@ public class SocketConsoleApplicationShell implements Runnable {
         app.exit();
     }
 
+    /** a method to wait some time */
+    protected void waitASec() {
+        try {
+            synchronized (this) {
+                wait(ONE_TENTH_OF_SECOND);
+            }
+        } catch (InterruptedException e) {
+            LOGGER.log(Level.SEVERE, "Interrupted wait", //$NON-NLS-1$
+                    e);
+            return;
+        }
+    }
+
+    /* (non-Javadoc)
+     * @see java.lang.AutoCloseable#close() */
+    @Override
+    public void close() throws Exception {
+        consoleManager.close();
+    }
 }

gclc-socket/src/test/java/fr/bigeon/gclc/socket/ConsoleRunnableTest.java

@@ -42,14 +42,12 @@ import java.io.IOException;
 
 import org.junit.Test;
 
-import fr.bigeon.gclc.ConsoleApplication;
 import fr.bigeon.gclc.manager.ConsoleManager;
-import fr.bigeon.gclc.manager.SystemConsoleManager;
 
 /** Test class for {@link ConsoleRunnable}
  *
  * @author Emmanuel Bigeon */
-@SuppressWarnings({"static-method", "unused", "javadoc"})
+@SuppressWarnings({"unused", "javadoc"})
 public class ConsoleRunnableTest {
 
     /** <p>
@@ -137,48 +135,48 @@ public class ConsoleRunnableTest {
      * . */
     @Test
     public void testConsoleRunnable() {
-        ConsoleApplication app = new ConsoleTestApplication(
-                new SystemConsoleManager());
-        ConsoleRunnable runnable = new ConsoleRunnable(app);
+//        ConsoleApplication app = new ConsoleTestApplication(
+//                new SystemConsoleManager());
+//        ConsoleRunnable runnable = new ConsoleRunnable(app);
 
     }
 
     /** Test method for {@link fr.bigeon.gclc.socket.ConsoleRunnable#run()}. */
     @Test
     public void testRunFlow() {
-        ConsoleApplication app = new ConsoleTestApplication(
-                new ConsoleManagerTestImplementation(
-                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
-        ConsoleRunnable runnable = new ConsoleRunnable(app);
-
-        Thread th = new Thread(runnable);
-        th.start();
-
-        runnable.stop();
+//        ConsoleApplication app = new ConsoleTestApplication(
+//                new ConsoleManagerTestImplementation(
+//                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
+//        ConsoleRunnable runnable = new ConsoleRunnable(app);
+//
+//        Thread th = new Thread(runnable);
+//        th.start();
+//
+//        runnable.stop();
     }
 
     /** Test method for {@link fr.bigeon.gclc.socket.ConsoleRunnable#stop()}. */
     @Test
     public void testStop() {
-        ConsoleApplication app = new ConsoleTestApplication(
-                new ConsoleManagerTestImplementation(
-                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
-        ConsoleRunnable runnable = new ConsoleRunnable(app);
-        runnable.stop();
-        Thread th = new Thread(runnable);
-        th.start();
-        runnable.stop();
-        runnable.stop();
+//        ConsoleApplication app = new ConsoleTestApplication(
+//                new ConsoleManagerTestImplementation(
+//                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
+//        ConsoleRunnable runnable = new ConsoleRunnable(app);
+//        runnable.stop();
+//        Thread th = new Thread(runnable);
+//        th.start();
+//        runnable.stop();
+//        runnable.stop();
     }
 
     /** Test method for {@link fr.bigeon.gclc.socket.ConsoleRunnable#stop()}. */
     @Test
     public void testRun() {
-        ConsoleApplication app = new ConsoleTestApplication(
-                new ConsoleManagerTestImplementation(
-                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
-        ConsoleRunnable runnable = new ConsoleRunnable(app);
-        runnable.run();
+//        ConsoleApplication app = new ConsoleTestApplication(
+//                new ConsoleManagerTestImplementation(
+//                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
+//        ConsoleRunnable runnable = new ConsoleRunnable(app);
+//        runnable.run();
     }
 
 }

gclc-socket/src/test/java/fr/bigeon/gclc/socket/SocketConsoleApplicationTest.java

@@ -48,20 +48,18 @@ import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.PrintWriter;
 import java.net.Socket;
-import java.util.Arrays;
+import java.util.logging.Logger;
 
 import org.junit.Test;
 
-import fr.bigeon.smu.StringEncoder;
-
 /** Test class for {@link SocketConsoleApplicationShell}
  * 
  * @author Emmanuel Bigeon */
 @SuppressWarnings({"static-method", "unused", "javadoc", "nls"})
 public class SocketConsoleApplicationTest {
 
-    private static final StringEncoder ENCODER = new StringEncoder("%",
-            Arrays.asList("\n")); //$NON-NLS-1$
+    private static final Logger LOGGER = Logger
+            .getLogger(SocketConsoleApplicationTest.class.getName());
 
     @Test
     public void integrationTest() {
@@ -90,14 +88,13 @@ public class SocketConsoleApplicationTest {
             int i = 0;
             String[] cmds = {"help", "toto", "test", "bye"};
             while ((fromServer = in.readLine()) != null) {
-                System.out.println("Server: \n" + ENCODER.decode(fromServer));
+                LOGGER.fine("Server: \n" + fromServer);
                 if (fromServer.equals("Bye.")) {
                     break;
                 }
                 while (fromServer != null && !fromServer.equals("> ")) {
                     fromServer = in.readLine();
-                    System.out
-                            .println("Server: \n" + ENCODER.decode(fromServer));
+                    LOGGER.fine("Server: \n" + fromServer);
                 }
                 if (fromServer == null) {
                     fail("Null pointer");
@@ -105,7 +102,7 @@ public class SocketConsoleApplicationTest {
 
                 final String fromUser = cmds[i];
                 if (fromUser != null) {
-                    System.out.println("Client: " + fromUser);
+                    LOGGER.fine("Client: " + fromUser);
                     out.println(fromUser);
                 }
                 i++;
@@ -126,19 +123,19 @@ public class SocketConsoleApplicationTest {
             String[] cmds = {"help", "toto", "test",
                     ConsoleTestApplication.EXIT};
             while ((fromServer = in.readLine()) != null) {
-                System.out.println("Server: \n" + ENCODER.decode(fromServer));
+                LOGGER.fine("Server: \n" + fromServer);
                 while (fromServer != null && !fromServer.equals("> ")) {
+                    LOGGER.fine("Server: \n" + fromServer);
                     fromServer = in.readLine();
-                    System.out
-                            .println("Server: \n" + ENCODER.decode(fromServer));
                 }
                 if (fromServer == null) {
                     break;
                 }
+                LOGGER.fine("Server: \n" + fromServer);
 
                 final String fromUser = cmds[i];
                 if (fromUser != null) {
-                    System.out.println("Client: " + fromUser);
+                    LOGGER.fine("Client: " + fromUser);
                     out.println(fromUser);
                 }
                 i++;
@@ -166,8 +163,7 @@ public class SocketConsoleApplicationTest {
             while ((fromServer = in.readLine()) != null) {
                 while (fromServer != null && !fromServer.equals("> ")) {
                     fromServer = in.readLine();
-                    System.out
-                            .println("Server: \n" + ENCODER.decode(fromServer));
+                    LOGGER.fine("Server: \n" + fromServer);
                 }
                 if (fromServer == null) {
                     break;
@@ -175,7 +171,7 @@ public class SocketConsoleApplicationTest {
 
                 final String fromUser = cmds[i];
                 if (fromUser != null) {
-                    System.out.println("Client: " + fromUser);
+                    LOGGER.fine("Client: " + fromUser);
                     out.println(fromUser);
                 }
                 i++;
@@ -215,8 +211,7 @@ public class SocketConsoleApplicationTest {
                 while (fromServer != null && !fromServer.equals("> ") &&
                        !fromServer.equals("See you")) {
                     fromServer = in.readLine();
-                    System.out
-                            .println("Server: \n" + ENCODER.decode(fromServer));
+                    LOGGER.fine("Server: \n" + fromServer);
                 }
                 if (fromServer == null || fromServer.equals("Bye.") ||
                     fromServer.equals("See you")) {
@@ -225,7 +220,7 @@ public class SocketConsoleApplicationTest {
 
                 final String fromUser = cmds[i];
                 if (fromUser != null) {
-                    System.out.println("Client: " + fromUser);
+                    LOGGER.fine("Client: " + fromUser);
                     out.println(fromUser);
                 }
                 i++;

gclc-swt/pom.xml

@@ -32,12 +32,10 @@
 <!-- The fact that you are presently reading this means that you have had      -->
 <!-- knowledge of the CeCILL license and that you accept its terms.            -->
 
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"
->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <artifactId>gclc-swt</artifactId>
-  <version>1.1.0-SNAPSHOT</version>
+  <version>1.1.2-SNAPSHOT</version>
   <packaging>jar</packaging>
   <url>http://www.bigeon.fr/emmanuel</url>
   <properties>
@@ -53,7 +51,7 @@
     <dependency>
       <groupId>fr.bigeon</groupId>
       <artifactId>gclc</artifactId>
-      <version>1.3.0</version>
+      <version>1.3.2</version>
     </dependency>
     <dependency>
       <groupId>fr.bigeon</groupId>

gclc-swt/src/main/java/fr/bigeon/gclc/swt/ConsoleDelayIO.java

@@ -38,8 +38,6 @@
  */
 package fr.bigeon.gclc.swt;
 
-import fr.bigeon.gclc.manager.ConsoleManager;
-
 /** This class represents an object used to send commands to a console
  * application.
  * <p>
@@ -47,7 +45,7 @@ import fr.bigeon.gclc.manager.ConsoleManager;
  * and set, and then validate the input.
  *
  * @author Emmanuel Bigeon */
-public interface ConsoleDelayIO extends ConsoleManager {
+public interface ConsoleDelayIO {
     /** Actually send the input as the prompt next input. */
     void validateInput();
 

gclc-swt/src/main/java/fr/bigeon/gclc/swt/SWTConsole.java

@@ -53,12 +53,14 @@ import org.eclipse.swt.widgets.Label;
 import org.eclipse.swt.widgets.Text;
 
 import fr.bigeon.gclc.ConsoleApplication;
+import fr.bigeon.gclc.manager.ConsoleManager;
 
 /** A SWT component to connect to gclc {@link ConsoleApplication}
  * <p>
  *
  * @author Emmanuel Bigeon */
-public class SWTConsole extends Composite implements ConsoleDelayIO {
+public class SWTConsole extends Composite
+        implements ConsoleDelayIO, ConsoleManager {
     /**
      *
      */
@@ -173,7 +175,9 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
             @SuppressWarnings("synthetic-access")
             @Override
             public void run() {
-                consoleOutput.append(text);
+                if (!consoleOutput.isDisposed()) {
+                    consoleOutput.append(text);
+                }
             }
         });
     }
@@ -186,7 +190,9 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
             @SuppressWarnings("synthetic-access")
             @Override
             public void run() {
-                consoleOutput.append(System.lineSeparator());
+                if (!consoleOutput.isDisposed()) {
+                    consoleOutput.append(System.lineSeparator());
+                }
             }
         });
     }
@@ -199,7 +205,9 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
             @SuppressWarnings("synthetic-access")
             @Override
             public void run() {
-                consoleOutput.append(message + System.lineSeparator());
+                if (!consoleOutput.isDisposed()) {
+                    consoleOutput.append(message + System.lineSeparator());
+                }
             }
         });
 
@@ -218,8 +226,10 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
                     @SuppressWarnings("synthetic-access")
                     @Override
                     public void run() {
-                        consoleInput.setEnabled(true);
-                        consoleInput.setFocus();
+                        if (!consoleInput.isDisposed()) {
+                            consoleInput.setEnabled(true);
+                            consoleInput.setFocus();
+                        }
                     }
                 });
                 prompting = true;
@@ -250,11 +260,13 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
                     @SuppressWarnings("synthetic-access")
                     @Override
                     public void run() {
-                        lblPromptlabel.setText(message);
-                        // relayout
-                        SWTConsole.this.layout();
-                        consoleInput.setEnabled(true);
-                        consoleInput.setFocus();
+                        if (!consoleOutput.isDisposed()) {
+                            lblPromptlabel.setText(message);
+                            // relayout
+                            SWTConsole.this.layout();
+                            consoleInput.setEnabled(true);
+                            consoleInput.setFocus();
+                        }
                     }
                 });
                 prompting = true;
@@ -271,9 +283,11 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
                     @SuppressWarnings("synthetic-access")
                     @Override
                     public void run() {
-                        lblPromptlabel.setText(prompt);
-                        // relayout
-                        SWTConsole.this.layout();
+                        if (!consoleOutput.isDisposed()) {
+                            lblPromptlabel.setText(prompt);
+                            // relayout
+                            SWTConsole.this.layout();
+                        }
                     }
                 });
             }
@@ -297,9 +311,11 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
             @SuppressWarnings("synthetic-access")
             @Override
             public void run() {
-                lblPromptlabel.setText(prompt);
-                // relayout
-                SWTConsole.this.layout();
+                if (!consoleOutput.isDisposed()) {
+                    lblPromptlabel.setText(prompt);
+                    // relayout
+                    SWTConsole.this.layout();
+                }
             }
         });
     }
@@ -352,4 +368,13 @@ public class SWTConsole extends Composite implements ConsoleDelayIO {
         return consoleInput.getText();
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleManager#interruptPrompt() */
+    @Override
+    public void interruptPrompt() {
+        synchronized (promptLock) {
+            promptLock.notify();
+        }
+    }
+
 }

gclc-swt/src/main/java/fr/bigeon/gclc/swt/SWTConsoleView.java

@@ -0,0 +1,204 @@
+/*
+ * Copyright E. Bigeon (2015)
+ *
+ * emmanuel@bigeon.fr
+ *
+ * This software is a computer program whose purpose is to
+ * provide a swt window for console applications.
+ *
+ * This software is governed by the CeCILL license under French law and
+ * abiding by the rules of distribution of free software.  You can  use,
+ * modify and/or redistribute the software under the terms of the CeCILL
+ * license as circulated by CEA, CNRS and INRIA at the following URL
+ * "http://www.cecill.info".
+ *
+ * As a counterpart to the access to the source code and  rights to copy,
+ * modify and redistribute granted by the license, users are provided only
+ * with a limited warranty  and the software's author,  the holder of the
+ * economic rights,  and the successive licensors  have only  limited
+ * liability.
+ *
+ * In this respect, the user's attention is drawn to the risks associated
+ * with loading,  using,  modifying and/or developing or reproducing the
+ * software by the user in light of its specific status of free software,
+ * that may mean  that it is complicated to manipulate,  and  that  also
+ * therefore means  that it is reserved for developers  and  experienced
+ * professionals having in-depth computer knowledge. Users are therefore
+ * encouraged to load and test the software's suitability as regards their
+ * requirements in conditions enabling the security of their systems and/or
+ * data to be ensured and,  more generally, to use and operate it in the
+ * same conditions as regards security.
+ *
+ * The fact that you are presently reading this means that you have had
+ * knowledge of the CeCILL license and that you accept its terms.
+ */
+/**
+ * gclc-swt:fr.bigeon.gclc.swt.SWTConsole.java
+ * Created on: Apr 18, 2015
+ */
+package fr.bigeon.gclc.swt;
+
+import java.io.IOException;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import org.eclipse.swt.SWT;
+import org.eclipse.swt.events.FocusAdapter;
+import org.eclipse.swt.events.FocusEvent;
+import org.eclipse.swt.layout.GridData;
+import org.eclipse.swt.layout.GridLayout;
+import org.eclipse.swt.widgets.Composite;
+import org.eclipse.swt.widgets.Display;
+import org.eclipse.swt.widgets.Text;
+
+import fr.bigeon.gclc.ConsoleApplication;
+import fr.bigeon.gclc.manager.PipedConsoleManager;
+import fr.bigeon.gclc.tools.AOutputForwardRunnable;
+
+/** A SWT component to connect to gclc {@link ConsoleApplication}
+ * <p>
+ *
+ * @author Emmanuel Bigeon */
+public class SWTConsoleView extends Composite implements ConsoleDelayIO {
+    /** The local implementation of the forwarding runnable
+     * 
+     * @author Emmanuel Bigeon */
+    private final class ToSWTConsoleForwardRunnable
+            extends AOutputForwardRunnable {
+        /** The running status */
+        private boolean running = true;
+
+        /** @param manager the manager */
+        public ToSWTConsoleForwardRunnable(PipedConsoleManager manager) {
+            super(manager);
+        }
+
+        @Override
+        protected void forwardLine(String m) {
+            appendConsoleOutput(m);
+        }
+
+        @Override
+        protected boolean isRunning() {
+            return running && !isDisposed();
+        }
+
+        /** @param running the running to set */
+        public void setRunning(boolean running) {
+            this.running = running;
+        }
+    }
+
+    /** The class logger */
+    private static final Logger LOGGER = Logger
+            .getLogger(SWTConsoleView.class.getName());
+    /** The console output text field */
+    private final Text consoleOutput;
+    /** The console input text field */
+    private final Text consoleInput;
+    /** The actual manager */
+    private PipedConsoleManager manager;
+    /** The forwarding runnable */
+    private ToSWTConsoleForwardRunnable forward;
+
+    /** Create the composite.
+     *
+     * @param parent the prent composite
+     * @param style the composite style */
+    public SWTConsoleView(Composite parent, int style) {
+        super(parent, style);
+
+        setLayout(new GridLayout(1, false));
+
+        consoleOutput = new Text(this, SWT.BORDER | SWT.READ_ONLY | SWT.WRAP |
+                                       SWT.V_SCROLL | SWT.MULTI);
+        consoleOutput.setLayoutData(new GridData(SWT.FILL, SWT.FILL, true, true,
+                1, 1));
+        consoleOutput.setRedraw(true);
+        consoleOutput.addFocusListener(new FocusAdapter() {
+            @SuppressWarnings("synthetic-access")
+            @Override
+            public void focusGained(FocusEvent e) {
+                consoleInput.setFocus();
+            }
+        });
+
+        consoleInput = new Text(this, SWT.BORDER);
+        consoleInput.setLayoutData(
+                new GridData(SWT.FILL, SWT.CENTER, true, false, 1, 1));
+        consoleInput.addKeyListener(new HistoryTextKeyListener(this));
+    }
+
+    /** @param manager the manager to set */
+    public void setManager(PipedConsoleManager manager) {
+        this.manager = manager;
+        if (forward != null) {
+            forward.setRunning(false);
+        }
+        forward = new ToSWTConsoleForwardRunnable(manager);
+        Thread th = new Thread(forward, "gclcToSWT"); //$NON-NLS-1$
+        th.start();
+    }
+
+    /** @param next the next message */
+    protected void appendConsoleOutput(final String next) {
+        Display.getDefault().syncExec(new Runnable() {
+            @SuppressWarnings("synthetic-access")
+            @Override
+            public void run() {
+                consoleOutput.append(System.lineSeparator() + next);
+            }
+        });
+    }
+
+    /**
+     * 
+     */
+    @Override
+    public void validateInput() {
+        try {
+            manager.type(getInput());
+        } catch (IOException e) {
+            LOGGER.log(Level.SEVERE, "Unable to input value to console", e); //$NON-NLS-1$
+        }
+    }
+
+    @Override
+    protected void checkSubclass() {
+        // Disable the check that prevents subclassing of SWT components
+    }
+
+    /* (non-Javadoc)
+     * @see org.eclipse.swt.widgets.Composite#setFocus() */
+    @Override
+    public boolean setFocus() {
+        return consoleInput.setFocus();
+    }
+
+    /** @param string the text */
+    public void setText(String string) {
+        consoleInput.setText(string);
+    }
+
+    /**
+     * 
+     */
+    public void validateCommand() {
+        validateInput();
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#setInput(java.lang.String) */
+    @Override
+    public void setInput(String input) {
+        consoleInput.setText(input);
+        consoleInput.setSelection(input.length());
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#getInput() */
+    @Override
+    public String getInput() {
+        return consoleInput.getText();
+    }
+}

gclc-swt/src/test/java/fr/bigeon/gclc/swt/HistoryTextKeyListenerTest.java

@@ -40,8 +40,6 @@ package fr.bigeon.gclc.swt;
 
 import static org.junit.Assert.assertEquals;
 
-import java.io.IOException;
-
 import org.eclipse.swt.SWT;
 import org.junit.Test;
 
@@ -58,51 +56,6 @@ public class HistoryTextKeyListenerTest {
         ConsoleDelayIO io = new ConsoleDelayIO() {
             private String input = "";
 
-            @Override
-            public void setPrompt(String prompt) {
-                //
-            }
-
-            @Override
-            public String prompt(String message) throws IOException {
-                return null;
-            }
-
-            @Override
-            public String prompt() throws IOException {
-                return null;
-            }
-
-            @Override
-            public void println(String message) throws IOException {
-                //
-            }
-
-            @Override
-            public void println() throws IOException {
-                //
-            }
-
-            @Override
-            public void print(String text) throws IOException {
-                //
-            }
-
-            @Override
-            public boolean isClosed() {
-                return false;
-            }
-
-            @Override
-            public String getPrompt() {
-                return null;
-            }
-
-            @Override
-            public void close() throws IOException {
-                //
-            }
-
             @Override
             public void validateInput() {
                 input = "";

gclc-swt/src/test/java/fr/bigeon/gclc/swt/SWTConsoleShellTest.java

@@ -39,7 +39,9 @@
 package fr.bigeon.gclc.swt;
 
 import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
 import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
 
 import java.io.IOException;
 
@@ -48,6 +50,7 @@ import org.junit.Test;
 
 import fr.bigeon.gclc.ConsoleApplication;
 import fr.bigeon.gclc.command.Command;
+import fr.bigeon.gclc.command.ExitCommand;
 import fr.bigeon.gclc.exception.CommandRunException;
 import fr.bigeon.gclc.exception.InvalidCommandName;
 
@@ -59,7 +62,7 @@ import fr.bigeon.gclc.exception.InvalidCommandName;
 public class SWTConsoleShellTest {
 
     protected static final long TWO_SECONDS = 2000;
-    private static final Display DISPLAY = new Display();
+    private static final Display DISPLAY = Display.getDefault();
 
     @Test
     public void testConsoleClose() {
@@ -69,7 +72,8 @@ public class SWTConsoleShellTest {
         swtConsole.setPrompt(":");
         try {
             final ConsoleApplication appl = new ConsoleApplication(swtConsole,
-                    "exit", "Hello", "See you");
+                    "Hello", "See you");
+            appl.add(new ExitCommand("exit", appl));
             appl.add(new Command("long") {
 
                 @Override
@@ -169,6 +173,7 @@ public class SWTConsoleShellTest {
                             shell.dispose();
                         }
                     });
+
                 }
             });
             applThread.start();
@@ -178,6 +183,13 @@ public class SWTConsoleShellTest {
                     DISPLAY.sleep();
                 }
             }
+            swtConsole.setPrompt(">");
+            try {
+                swtConsole.prompt();
+                fail("Prompting when closed should fail!");
+            } catch (IOException e) {
+                assertNotNull(e);
+            }
 //            DISPLAY.dispose();
             assertTrue(appl.getManager().isClosed());
             Thread.sleep(TWO_SECONDS);
@@ -197,7 +209,8 @@ public class SWTConsoleShellTest {
         final SWTConsole swtConsole = (SWTConsole) shell.getManager();
         try {
             final ConsoleApplication appl = new ConsoleApplication(swtConsole,
-                    "exit", "Hello", "See you");
+                    "Hello", "See you");
+            appl.add(new ExitCommand("exit", appl));
             appl.add(new Command("long") {
 
                 @Override

gclc-swt/src/test/java/fr/bigeon/gclc/swt/SWTConsoleViewTest.java

@@ -0,0 +1,145 @@
+/*
+ * Copyright E. Bigeon (2015)
+ *
+ * emmanuel@bigeon.fr
+ *
+ * This software is a computer program whose purpose is to
+ * provide a swt window for console applications.
+ *
+ * This software is governed by the CeCILL license under French law and
+ * abiding by the rules of distribution of free software.  You can  use,
+ * modify and/or redistribute the software under the terms of the CeCILL
+ * license as circulated by CEA, CNRS and INRIA at the following URL
+ * "http://www.cecill.info".
+ *
+ * As a counterpart to the access to the source code and  rights to copy,
+ * modify and redistribute granted by the license, users are provided only
+ * with a limited warranty  and the software's author,  the holder of the
+ * economic rights,  and the successive licensors  have only  limited
+ * liability.
+ *
+ * In this respect, the user's attention is drawn to the risks associated
+ * with loading,  using,  modifying and/or developing or reproducing the
+ * software by the user in light of its specific status of free software,
+ * that may mean  that it is complicated to manipulate,  and  that  also
+ * therefore means  that it is reserved for developers  and  experienced
+ * professionals having in-depth computer knowledge. Users are therefore
+ * encouraged to load and test the software's suitability as regards their
+ * requirements in conditions enabling the security of their systems and/or
+ * data to be ensured and,  more generally, to use and operate it in the
+ * same conditions as regards security.
+ *
+ * The fact that you are presently reading this means that you have had
+ * knowledge of the CeCILL license and that you accept its terms.
+ */
+/**
+ * gclc-swt:fr.bigeon.gclc.swt.SWTConsoleShellTest.java
+ * Created on: Jun 8, 2016
+ */
+package fr.bigeon.gclc.swt;
+
+import java.io.IOException;
+
+import org.eclipse.swt.SWT;
+import org.eclipse.swt.widgets.Display;
+import org.eclipse.swt.widgets.Shell;
+import org.junit.Test;
+
+import fr.bigeon.gclc.ConsoleApplication;
+import fr.bigeon.gclc.command.Command;
+import fr.bigeon.gclc.command.ExitCommand;
+import fr.bigeon.gclc.exception.InvalidCommandName;
+import fr.bigeon.gclc.manager.PipedConsoleManager;
+
+/** <p>
+ * TODO
+ *
+ * @author Emmanuel Bigeon */
+@SuppressWarnings({"javadoc", "static-method", "nls", "deprecation"})
+public class SWTConsoleViewTest {
+
+    protected static final long TWO_SECONDS = 2000;
+    private static final Display DISPLAY = Display.getDefault();
+
+    @Test
+    public void test() {
+        final Shell shell = new Shell(DISPLAY);
+        final SWTConsoleView swtConsole = new SWTConsoleView(shell, SWT.NONE);
+        try (PipedConsoleManager manager = new PipedConsoleManager()) {
+            swtConsole.setManager(manager);
+            final ConsoleApplication appl = new ConsoleApplication(manager,
+                    "Hello", "See you");
+            appl.add(new ExitCommand("exit", appl));
+            appl.add(new Command("long") {
+
+                @Override
+                public String tip() {
+                    return "a long running command";
+                }
+
+                @Override
+                public void execute(String... args) {
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+            });
+//            shell.pack();
+            shell.open();
+            Thread applThread = new Thread(new Runnable() {
+
+                @Override
+                public void run() {
+                    appl.start();
+                }
+            });
+            Thread testThread = new Thread(new Runnable() {
+
+                @Override
+                public void run() {
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                    Display.getDefault().syncExec(new Runnable() {
+                        @Override
+                        public void run() {
+                            swtConsole.setText("test"); //$NON-NLS-1$
+                            swtConsole.validateCommand();
+                        }
+                    });
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                    Display.getDefault().syncExec(new Runnable() {
+                        @Override
+                        public void run() {
+                            shell.dispose();
+                        }
+                    });
+                }
+            });
+            applThread.start();
+            testThread.start();
+            while (!shell.isDisposed()) {
+                if (!DISPLAY.readAndDispatch()) {
+                    DISPLAY.sleep();
+                }
+            }
+        } catch (InvalidCommandName e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        } catch (IOException e1) {
+            // TODO Auto-generated catch block
+            e1.printStackTrace();
+        }
+    }
+}

gclc.system/pom.xml

@@ -23,7 +23,7 @@
     <dependency>
       <groupId>fr.bigeon</groupId>
       <artifactId>gclc</artifactId>
-      <version>1.2.6</version>
+      <version>1.3.1</version>
     </dependency>
   </dependencies>
   <name>GCLC system command</name>

gclc.system/src/main/java/net/bigeon/gclc/system/ExecSystemCommand.java

@@ -17,8 +17,7 @@ import fr.bigeon.gclc.exception.CommandRunException;
 import fr.bigeon.gclc.exception.CommandRunExceptionType;
 import fr.bigeon.gclc.manager.ConsoleManager;
 
-/** <p>
- * TODO
+/** A command that will execute a system command.
  *
  * @author Emmanuel Bigeon */
 public class ExecSystemCommand extends Command {
@@ -79,7 +78,7 @@ public class ExecSystemCommand extends Command {
             }
         });
         th.start();
-        manager.setPrompt("");
+        manager.setPrompt(""); //$NON-NLS-1$
         final OutputStream os = proc.getOutputStream();
         try (BufferedWriter writer = new BufferedWriter(
                 new OutputStreamWriter(os))) {

gclc/pom.xml

@@ -35,7 +35,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<artifactId>gclc</artifactId>
-	<version>1.3.1</version>
+	<version>1.3.3-SNAPSHOT</version>
 	<packaging>jar</packaging>
 	<url>http://www.bigeon.fr/emmanuel</url>
 	<properties>
@@ -83,6 +83,6 @@
   <scm>
   
     <developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
-	<tag>gclc-1.3.1</tag>
+	<tag>HEAD</tag>
   </scm>
 </project>

gclc/src/main/java/fr/bigeon/gclc/manager/ConsoleManager.java

@@ -48,7 +48,7 @@ import java.io.InterruptedIOException;
  * a message, in that case, the usual behavior is to prompt normally.
  *
  * @author Emmanuel BIGEON */
-public interface ConsoleManager {
+public interface ConsoleManager extends AutoCloseable {
 
     /** @return the prompt prefix */
     String getPrompt();
@@ -89,12 +89,18 @@ public interface ConsoleManager {
     /** Closes the manager.
      * 
      * @throws IOException if the close raised an exception */
+    @Override
     void close() throws IOException;
 
     /** @return if the manager is closed. */
     boolean isClosed();
 
     /** Indicate to the manager that is should interrompt the prompting, if
-     * possible. */
+     * possible.
+     * <p>
+     * The pending {@link #prompt()} or {@link #prompt(String)} operations
+     * should return immediatly. However the returned value can be anything
+     * (from the partial prompt content to an empty string or even a null
+     * pointer). */
     void interruptPrompt();
 }

gclc/src/main/java/fr/bigeon/gclc/manager/PipedConsoleManager.java

@@ -54,7 +54,7 @@ import java.nio.charset.Charset;
  *
  * @author Emmanuel Bigeon */
 public final class PipedConsoleManager
-        implements ConsoleManager, AutoCloseable {
+        implements ConsoleManager {
 
     /** The encoding between streams */
     private static final String UTF_8 = "UTF-8"; //$NON-NLS-1$
@@ -91,6 +91,7 @@ public final class PipedConsoleManager
         Thread th = new Thread(writing, "write"); //$NON-NLS-1$
         th.start();
         th = new Thread(reading, "read"); //$NON-NLS-1$
+        th.setDaemon(true);
         th.start();
     }
 

gclc/src/main/java/fr/bigeon/gclc/manager/SystemConsoleManager.java

@@ -88,6 +88,7 @@ public final class SystemConsoleManager implements ConsoleManager { // NOSONAR
         this.in = new BufferedReader(new InputStreamReader(in, charset));
         reading = new ReadingRunnable(this.in);
         promptThread = new Thread(reading, "prompt"); //$NON-NLS-1$
+        promptThread.setDaemon(true);
         promptThread.start();
     }
 
@@ -156,6 +157,7 @@ public final class SystemConsoleManager implements ConsoleManager { // NOSONAR
     public void close() throws IOException {
         closed = true;
         reading.setRunning(false);
+        promptThread.interrupt();
     }
 
     /* (non-Javadoc)

gclc/src/main/java/fr/bigeon/gclc/tools/AOutputForwardRunnable.java

@@ -0,0 +1,130 @@
+/*
+ * Copyright Bigeon Emmanuel (2014)
+ *
+ * emmanuel@bigeon.fr
+ *
+ * This software is a computer program whose purpose is to
+ * provide a generic framework for console applications.
+ *
+ * This software is governed by the CeCILL license under French law and
+ * abiding by the rules of distribution of free software.  You can  use,
+ * modify and/or redistribute the software under the terms of the CeCILL
+ * license as circulated by CEA, CNRS and INRIA at the following URL
+ * "http://www.cecill.info".
+ *
+ * As a counterpart to the access to the source code and  rights to copy,
+ * modify and redistribute granted by the license, users are provided only
+ * with a limited warranty  and the software's author,  the holder of the
+ * economic rights,  and the successive licensors  have only  limited
+ * liability.
+ *
+ * In this respect, the user's attention is drawn to the risks associated
+ * with loading,  using,  modifying and/or developing or reproducing the
+ * software by the user in light of its specific status of free software,
+ * that may mean  that it is complicated to manipulate,  and  that  also
+ * therefore means  that it is reserved for developers  and  experienced
+ * professionals having in-depth computer knowledge. Users are therefore
+ * encouraged to load and test the software's suitability as regards their
+ * requirements in conditions enabling the security of their systems and/or
+ * data to be ensured and,  more generally, to use and operate it in the
+ * same conditions as regards security.
+ *
+ * The fact that you are presently reading this means that you have had
+ * knowledge of the CeCILL license and that you accept its terms.
+ */
+/**
+ * gclc:fr.bigeon.gclc.tools.AOutputForwardRunnable.java
+ * Created on: Dec 1, 2016
+ */
+package fr.bigeon.gclc.tools;
+
+import java.io.IOException;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import fr.bigeon.gclc.manager.PipedConsoleManager;
+
+/** An incomplete implematation used to forward messages from a piped console.
+ * <p>
+ * This forwarding can be interrupted without closing the piped manager.
+ *
+ * @author Emmanuel Bigeon */
+public abstract class AOutputForwardRunnable implements Runnable {
+
+    /** The class logger */
+    private static final Logger LOGGER = Logger
+            .getLogger(AOutputForwardRunnable.class.getName());
+    /** The default timeout (one tenth of second). */
+    private static final long DEFAULT_TIMEOUT = 100;
+    /** The manager. */
+    private final PipedConsoleManager manager;
+    /** The timeout */
+    private final long timeout;
+
+    /** Create a forward runnable with the given timeout.
+     * <p>
+     * Short timeout will be very responsive to the application actual messages,
+     * but may use computation time if the application is not verbose. Long
+     * timeout will save computation time, but will read batches of messages at
+     * once if the application is verbose. The right length for the timeout is
+     * likely to depend on the application and the use of it.
+     * <p>
+     * If you do not know what timeout length to use, please use the
+     * {@link #AOutputForwardRunnable(PipedConsoleManager)} constructor.
+     * 
+     * @param manager the manager
+     * @param timeout the timeout between message requests. */
+    public AOutputForwardRunnable(PipedConsoleManager manager, long timeout) {
+        super();
+        this.manager = manager;
+        this.timeout = timeout;
+    }
+
+    /** Create a forwarding runnable.
+     * 
+     * @param manager the manager */
+    public AOutputForwardRunnable(PipedConsoleManager manager) {
+        super();
+        this.manager = manager;
+        timeout = DEFAULT_TIMEOUT;
+    }
+
+    @Override
+    public void run() {
+        try {
+            while (isRunning()) {
+                while (isRunning() && !manager.available()) {
+                    waitASec();
+                }
+                if (!isRunning()) {
+                    return;
+                }
+                String m = manager.readNextLine();
+                forwardLine(m);
+            }
+        } catch (IOException e) {
+            LOGGER.log(Level.SEVERE, "Unexpected problem in manager", //$NON-NLS-1$
+                    e);
+        }
+    }
+
+    /** @param m the line to forward */
+    protected abstract void forwardLine(String m);
+
+    /** @return if the thread should keep running */
+    protected abstract boolean isRunning();
+
+    /** a method to wait some time */
+    protected void waitASec() {
+        try {
+            synchronized (this) {
+                wait(timeout);
+            }
+        } catch (InterruptedException e) {
+            LOGGER.log(Level.SEVERE, "Interrupted wait", //$NON-NLS-1$
+                    e);
+            return;
+        }
+    }
+
+}

gclc/src/test/java/fr/bigeon/gclc/command/CommandParametersTest.java

@@ -55,6 +55,7 @@ import org.junit.Test;
  * @author Emmanuel Bigeon
  *
  */
+@SuppressWarnings({"static-method", "nls"})
 public class CommandParametersTest {
 
     /**

gclc/src/test/java/fr/bigeon/gclc/tools/AOutputForwardRunnableTest.java

@@ -0,0 +1,141 @@
+/*
+ * Copyright Bigeon Emmanuel (2014)
+ *
+ * emmanuel@bigeon.fr
+ *
+ * This software is a computer program whose purpose is to
+ * provide a generic framework for console applications.
+ *
+ * This software is governed by the CeCILL license under French law and
+ * abiding by the rules of distribution of free software.  You can  use,
+ * modify and/or redistribute the software under the terms of the CeCILL
+ * license as circulated by CEA, CNRS and INRIA at the following URL
+ * "http://www.cecill.info".
+ *
+ * As a counterpart to the access to the source code and  rights to copy,
+ * modify and redistribute granted by the license, users are provided only
+ * with a limited warranty  and the software's author,  the holder of the
+ * economic rights,  and the successive licensors  have only  limited
+ * liability.
+ *
+ * In this respect, the user's attention is drawn to the risks associated
+ * with loading,  using,  modifying and/or developing or reproducing the
+ * software by the user in light of its specific status of free software,
+ * that may mean  that it is complicated to manipulate,  and  that  also
+ * therefore means  that it is reserved for developers  and  experienced
+ * professionals having in-depth computer knowledge. Users are therefore
+ * encouraged to load and test the software's suitability as regards their
+ * requirements in conditions enabling the security of their systems and/or
+ * data to be ensured and,  more generally, to use and operate it in the
+ * same conditions as regards security.
+ *
+ * The fact that you are presently reading this means that you have had
+ * knowledge of the CeCILL license and that you accept its terms.
+ */
+/**
+ * gclc:fr.bigeon.gclc.tools.AOutputForwardRunnableTest.java
+ * Created on: Dec 3, 2016
+ */
+package fr.bigeon.gclc.tools;
+
+import static org.junit.Assert.assertEquals;
+
+import java.io.IOException;
+
+import org.junit.Test;
+
+import fr.bigeon.gclc.manager.PipedConsoleManager;
+
+/** <p>
+ * TODO
+ *
+ * @author Emmanuel Bigeon */
+public class AOutputForwardRunnableTest {
+
+    /** <p>
+     * TODO
+     *
+     * @author Emmanuel Bigeon */
+    private final class AOutputForwardTestRunnable
+            extends AOutputForwardRunnable {
+        private int count = 2;
+        private String message;
+
+        /** @param manager */
+        private AOutputForwardTestRunnable(PipedConsoleManager manager) {
+            super(manager);
+        }
+
+        @Override
+        protected boolean isRunning() {
+            return count != 0;
+        }
+
+        @Override
+        protected void forwardLine(String m) {
+            // Do nothing
+            message = m;
+            synchronized (this) {
+                notify();
+                try {
+                    wait();
+                } catch (InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+            }
+        }
+
+        /** @return the message */
+        public String getMessage() {
+            if (message == null) {
+                synchronized (this) {
+                    try {
+                        wait();
+                    } catch (InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+            }
+            String m = message;
+            count--;
+            message = null;
+            synchronized (this) {
+                notify();
+            }
+            return m;
+        }
+    }
+
+    /** Test method for
+     * {@link fr.bigeon.gclc.tools.AOutputForwardRunnable#run()}. */
+    @Test
+    public final void testRun() {
+        try (PipedConsoleManager manager = new PipedConsoleManager()) {
+            AOutputForwardTestRunnable runnable = new AOutputForwardTestRunnable(
+                    manager);
+
+            Thread th = new Thread(runnable, "forward");
+            manager.println("before");
+            th.start();
+
+            assertEquals("before", runnable.getMessage());
+
+            synchronized (this) {
+                wait(3000);
+            }
+            manager.println("after");
+            assertEquals("after", runnable.getMessage());
+            synchronized (this) {
+                wait(3000);
+            }
+
+            th.join();
+
+        } catch (IOException | InterruptedException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+    }
+}