[maven-release-plugin] prepare release gclc-2.0.4

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

gclc-socket/pom.xml

@@ -1,4 +1,35 @@
 
+<!-- GCLC Socket, Socket implementation of GCLC                                   -->
+<!-- Copyright (C) 2014-2017 E. Bigeon                      -->
+<!-- mailto:emmanuel@bigeon.fr                                                           -->
+<!--                                                                           -->
+<!-- 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.            -->
+
+
 <!-- Copyright E. Bigeon (2014)                             -->
 <!--                                                                           -->
 <!-- emmanuel@bigeon.fr                                                                  -->
@@ -70,7 +101,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.9-SNAPSHOT</version>
+  <version>1.1.10-SNAPSHOT</version>
   <packaging>jar</packaging>
   <url>http://www.bigeon.fr/emmanuel</url>
   <properties>
@@ -81,7 +112,7 @@ of Emmanuel Bigeon.                                                   -->
     <dependency>
     	<groupId>fr.bigeon</groupId>
     	<artifactId>gclc</artifactId>
-    	<version>2.0.0</version>
+    	<version>2.0.4-SNAPSHOT</version>
     </dependency>
     <dependency>
     	<groupId>fr.bigeon</groupId>

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

@@ -0,0 +1,98 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.ConnexionManager.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import java.util.Collection;
+
+/** A manager for connected elements.
+ * <p>
+ * Connected elements are given an identifier (unique) at connexion.
+ *
+ * @author Emmanuel Bigeon
+ * @param <T> the type of object connected */
+public interface ConnexionManager<T> {
+    /** Add a connection in the name.
+     *
+     * @param handle the connected object
+     * @return the name */
+    String addConnexion(T handle);
+
+    /** Disconnect an element.
+     *
+     * @param id the element connection id
+     * @return the object being disconnected */
+    T disconnect(String id);
+
+    /** Get the connected object.
+     *
+     * @param id the connexion id
+     * @return the object */
+    T get(String id);
+
+    /** Get the connected elements' ids.
+     *
+     * @return the connected elements' ids */
+    Collection<String> getConnected();
+
+    /** Test if a connection is active.
+     *
+     * @param id the connexion id
+     * @return if the connection is active. */
+    boolean isConnected(String id);
+
+    /** Add a lock on the disconnection.
+     * <p>
+     * This lock will <strong>not</strong> prevent calls to
+     * {@link #disconnect(String)}. It will however stop them from completing
+     * after the effective disconnection of the specified connection.
+     * <p>
+     * Calls to {@link #releaseDisconnexionLock(String)} remove a lock (at a
+     * pace of one for one).
+     *
+     * @param id the connexion id */
+    void lockDisconnexion(String id);
+
+    /** Release one lock on a disconnection
+     *
+     * @param id the connexion being released. */
+    void releaseDisconnexionLock(String id);
+
+    /** Wait for calls to {@link #disconnect(String)}
+     *
+     * @param id the connexion id
+     * @throws InterruptedException if the wait was interrupted. */
+    void waitDisconnexion(String id) throws InterruptedException;
+}

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

@@ -1,133 +0,0 @@
-/*
- * Copyright E. Bigeon (2014)
- *
- * emmanuel@bigeon.fr
- *
- * This software is a computer program whose purpose is to
- * Socket implementation of GCLC.
- *
- * 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-socket:fr.bigeon.gclc.socket.ConsoleRunnable.java
- * Created on: Jun 1, 2016
- */
-package fr.bigeon.gclc.socket;
-
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import fr.bigeon.gclc.ConsoleApplication;
-
-/** A runnable class that will actually have the application running.
- *
- * @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 */
-    public ConsoleRunnable(ConsoleApplication app) {
-        super();
-        this.app = app;
-    }
-
-    /* (non-Javadoc)
-     * @see java.lang.Runnable#run() */
-    @Override
-    public void run() {
-        while (running) {
-            synchronized (lock) {
-                while (running && !startReq) {
-                    try {
-                        lock.wait(TIMEOUT);
-                    } catch (InterruptedException e) {
-                        LOGGER.log(Level.SEVERE,
-                                "Console application runnable interrupted wildly!", //$NON-NLS-1$
-                                e);
-                        return;
-                    }
-                }
-                startReq = false;
-                if (!running) {
-                    return;
-                }
-                lock.notify();
-            }
-            app.start();
-        }
-    }
-
-    /** Stop the application (it will finish its current operation) */
-    public void stop() {
-        app.exit();
-    }
-
-    /** @return if the application is running */
-    public boolean isApplicationRunning() {
-        return app.isRunning();
-    }
-
-    /** @param running the running to set */
-    public void setRunning(boolean running) {
-        synchronized (lock) {
-            this.running = running;
-        }
-    }
-
-    /** @return the running */
-    public boolean isRunning() {
-        synchronized (lock) {
-            return running;
-        }
-    }
-
-    /** Request a restart of application */
-    public void restart() {
-        synchronized (lock) {
-            startReq = true;
-            lock.notify();
-            try {
-                lock.wait(TIMEOUT);
-            } catch (InterruptedException e) {
-                LOGGER.log(Level.SEVERE, "Restart wait interrupted!", e); //$NON-NLS-1$
-            }
-        }
-    }
-}

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

@@ -0,0 +1,173 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.DConnexionManager.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+/** Default implementation of the {@link ConnexionManager}.
+ *
+ * @author Emmanuel Bigeon
+ * @param <T> the connected objects */
+public final class DConnexionManager<T> implements ConnexionManager<T> {
+
+    /** Class logger. */
+    private static final Logger LOGGER = Logger
+            .getLogger(DConnexionManager.class.getName());
+    /** The connected objects. */
+    private final Map<String, T> connecteds = new HashMap<>();
+    /** The locks for the connexions. */
+    private final Map<String, Object> locks = new HashMap<>();
+    /** The counter for the disconnexion locks. */
+    private final Map<String, Integer> counters = new HashMap<>();
+    /** The lock for modification of {@link #counters}. */
+    private final Object counterLock = new Object();
+    /** The count of connexions. */
+    private int count = 0;
+
+    /** Default.constructor. */
+    public DConnexionManager() {
+        //
+    }
+    /* (non-Javadoc)
+     * @see
+     * fr.bigeon.gclc.socket.ConnexionManager#addConnexion(java.lang.Object) */
+    @Override
+    public String addConnexion(final T handle) {
+        final String newID = newID();
+        connecteds.put(newID, handle);
+        locks.put(newID, new Object());
+        counters.put(newID, Integer.valueOf(0));
+        return newID;
+    }
+
+    /* (non-Javadoc)
+     * @see
+     * fr.bigeon.gclc.socket.ConnexionManager#disconnect(java.lang.String) */
+    @Override
+    public T disconnect(final String id) {
+        if (connecteds.containsKey(id)) {
+            final T disc = connecteds.remove(id);
+            final Object lock = locks.get(id);
+            synchronized (lock) {
+                lock.notifyAll();
+            }
+            synchronized (counterLock) {
+                while (counters.get(id).intValue() > 0) {
+                    try {
+                        counterLock.wait();
+                    } catch (final InterruptedException e) {
+                        LOGGER.log(Level.FINE, "Interruption of thread", e); //$NON-NLS-1$
+                        Thread.currentThread().interrupt();
+                    }
+                }
+            }
+            return disc;
+        }
+        return null;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.socket.ConnexionManager#get(java.lang.String) */
+    @Override
+    public T get(final String id) {
+        return connecteds.get(id);
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.socket.ConnexionManager#getConnected() */
+    @Override
+    public Collection<String> getConnected() {
+        return connecteds.keySet();
+    }
+
+    /* (non-Javadoc)
+     * @see
+     * fr.bigeon.gclc.socket.ConnexionManager#isConnected(java.lang.String) */
+    @Override
+    public boolean isConnected(final String id) {
+        return connecteds.containsKey(id);
+    }
+
+    /* (non-Javadoc)
+     * @see
+     * fr.bigeon.gclc.socket.ConnexionManager#lockDisconnexion(java.lang.String) */
+    @Override
+    public void lockDisconnexion(final String id) {
+        if (!connecteds.containsKey(id)) {
+            return;
+        }
+        synchronized (counterLock) {
+            counters.put(id, Integer.valueOf(counters.get(id).intValue() + 1));
+        }
+    }
+
+    /** Get a new identifier for connexion.
+     *
+     * @return a new ID */
+    private String newID() {
+        return "Client " + count++; //$NON-NLS-1$
+    }
+
+    /* (non-Javadoc)
+     * @see
+     * fr.bigeon.gclc.socket.ConnexionManager#releaseDisconnexionLock(java.lang.
+     * String) */
+    @Override
+    public void releaseDisconnexionLock(final String id) {
+        synchronized (counterLock) {
+            counters.put(id, Integer
+                    .valueOf(Math.max(counters.get(id).intValue() - 1, 0)));
+            counterLock.notifyAll();
+        }
+    }
+
+    /* (non-Javadoc)
+     * @see
+     * fr.bigeon.gclc.socket.ConnexionManager#waitDisconnexion(java.lang.String) */
+    @Override
+    public void waitDisconnexion(final String id) throws InterruptedException {
+        final Object lock = locks.get(id);
+        while (connecteds.containsKey(id)) {
+            synchronized (lock) {
+                lock.wait();
+            }
+        }
+    }
+}

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

@@ -0,0 +1,284 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.PlugableConsoleInput.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.PrintStream;
+import java.nio.charset.StandardCharsets;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import fr.bigeon.gclc.manager.ConsoleInput;
+import fr.bigeon.gclc.manager.ReadingRunnable;
+import fr.bigeon.gclc.tools.ConstantString;
+import fr.bigeon.gclc.tools.StringProvider;
+
+/** A console input where the stream can be plugged.
+ * <p>
+ * This pluggable console input accepts an input and output to be connected to
+ * it. The connexion cannot be concurrent, which mean that any connected stream
+ * must be disconnected before a new call to
+ * {@link #connect(InputStream, PrintStream)} is done.
+ *
+ * @author Emmanuel Bigeon */
+public final class PluggableConsoleInput implements ConsoleInput {
+    /** The ten constant. */
+    private static final int TENTH = 10;
+    /** Class logger. */
+    private static final Logger LOGGER = Logger
+            .getLogger(PluggableConsoleInput.class.getName());
+    /** The default time out. */
+    private static final long TIMEOUT = 100;
+    /** The prompting. */
+    private boolean prompting = false;
+    /** If the element is closed. */
+    private boolean closed = false;
+    /** The default prompt. */
+    private StringProvider prompt = new ConstantString("> "); //$NON-NLS-1$
+    /** If the input is plugged or buffering. */
+    private boolean connected = false;
+    /** The current connexion (if any). */
+    private ReadingRunnable connexion;
+    /** The interrupted status for prompts. */
+    private boolean interrupted = false;
+    /** The last hint hint. */
+    private String hint;
+    /** The output for hints. */
+    private PrintStream output;
+
+    // Locks
+    /** The lock for connexion and disconnexion of actual streams. */
+    private final Object connexionLock = new Object();
+
+    /** Create the pluggable console input. */
+    public PluggableConsoleInput() {
+        // do nothing
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#close() */
+    @Override
+    public void close() {
+        closed = true;
+    }
+
+    /** Connect the given input stream to the input and output to the hints
+     * writing.
+     *
+     * @param stream the input stream
+     * @param out the output for hints.
+     * @throws IOException if the input is already connected. */
+    public void connect(final InputStream stream,
+                        final PrintStream out) throws IOException {
+        synchronized (connexionLock) {
+            if (connected) {
+                throw new IOException(
+                        "Input already connected to an input stream"); //$NON-NLS-1$
+            }
+
+            output = out;
+            if (prompting) {
+                out.print(hint);
+                out.flush();
+            }
+
+            final InputStreamReader streamReader = new InputStreamReader(
+                    stream, StandardCharsets.UTF_8);
+            final BufferedReader reader = new BufferedReader(streamReader);
+            connexion = new ReadingRunnable(reader);
+            final Thread th = new Thread(connexion, "GCLC Socket - Read input"); //$NON-NLS-1$
+            th.start();
+            connexionLock.notifyAll();
+            connected = true;
+        }
+    }
+
+    /** Disconnect the current input and hint output. */
+    public synchronized void disconnect() {
+        synchronized (connexionLock) {
+            if (!connected) {
+                return;
+            }
+            connected = false;
+            connexion.setRunning(false);
+        }
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#getPrompt() */
+    @Override
+    public StringProvider getPrompt() {
+        return prompt;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#interruptPrompt() */
+    @Override
+    public void interruptPrompt() {
+        interrupted = true;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#isClosed() */
+    @Override
+    public boolean isClosed() {
+        return closed;
+    }
+
+    /** Test if a prompt is occuring.
+     *
+     * @return the prompting */
+    public boolean isPrompting() {
+        return prompting;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#prompt() */
+    @Override
+    public String prompt() throws IOException {
+        return prompt(prompt.apply());
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#prompt(long) */
+    @Override
+    public String prompt(final long timeout) throws IOException {
+        return prompt(prompt.apply(), timeout);
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#prompt(java.lang.String) */
+    @Override
+    public String prompt(final String message) throws IOException {
+        if (closed) {
+            throw new IOException();
+        }
+        prompting = true;
+        hint = message;
+        synchronized (connexionLock) {
+            hint = message;
+            if (connected) {
+                output.print(message);
+                output.flush();
+            }
+        }
+
+        String res = null;
+        while (res == null && !interrupted) {
+            try {
+                res = waitMessageOrConnexion(TIMEOUT, TIMEOUT / TENTH);
+            } catch (final InterruptedException e) {
+                LOGGER.log(Level.FINE, "Interruption of thread", e); //$NON-NLS-1$
+                Thread.currentThread().interrupt();
+            }
+            if (closed) {
+                throw new IOException();
+            }
+        }
+        prompting = false;
+        return res;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#prompt(java.lang.String,
+     * long) */
+    @Override
+    public String prompt(final String message,
+                         final long timeout) throws IOException {
+        if (closed) {
+            throw new IOException();
+        }
+        prompting = true;
+        synchronized (connexionLock) {
+            hint = message;
+            if (connected) {
+                output.print(message);
+                output.flush();
+            }
+        }
+
+        String res = null;
+        final long tic = System.currentTimeMillis();
+        long time = System.currentTimeMillis() - tic;
+        while (res == null && !interrupted && time < timeout) {
+            try {
+                res = waitMessageOrConnexion(timeout - time,
+                        (timeout - time) / TENTH);
+            } catch (final InterruptedException e) {
+                LOGGER.log(Level.FINE, "Interruption of thread", e); //$NON-NLS-1$
+                Thread.currentThread().interrupt();
+            }
+            time = System.currentTimeMillis() - tic;
+            if (closed) {
+                throw new IOException();
+            }
+        }
+        prompting = false;
+        return res;
+    }
+
+    @Override
+    public void setPrompt(final StringProvider prompt) {
+        this.prompt = prompt;
+    }
+    
+    @Override
+    public void setPrompt(String prompt) {
+    	setPrompt(new ConstantString(prompt));
+    }
+
+    /** Wait for a hint or connexion.
+     *
+     * @param messageTimeout the timeout on the current connexion hint waiting
+     * @param connexionTimeout the timeout on the new connexion wait
+     * @return the hint, or null if not connected or timed out.
+     * @throws IOException if the reading failed.
+     * @throws InterruptedException if the wait was interrupted */
+    private String waitMessageOrConnexion(final long messageTimeout,
+                                          final long connexionTimeout) throws IOException,
+                                                                       InterruptedException {
+        synchronized (connexionLock) {
+            if (connected) {
+                return connexion.getNextMessage(messageTimeout);
+            }
+            connexionLock.wait(connexionTimeout);
+        }
+        return null;
+    }
+}

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

@@ -0,0 +1,126 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.PluggableConsoleOutput.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import java.io.IOException;
+import java.io.PrintStream;
+import java.util.ArrayDeque;
+import java.util.Deque;
+
+import fr.bigeon.gclc.manager.ConsoleOutput;
+
+/** An output that can be hotplugged to an actual output.
+ *
+ * @author Emmanuel Bigeon */
+public final class PluggableConsoleOutput implements ConsoleOutput {
+
+    /** The actual output. */
+    private PrintStream out;
+    /** The buffered messages. */
+    private final Deque<String> messages = new ArrayDeque<>();
+    /** If this output is closed. */
+    private boolean closed = false;
+
+    /** Default constructor. */
+    public PluggableConsoleOutput() {
+        //
+    }
+    /* (non-Javadoc)
+     * @see java.lang.AutoCloseable#close() */
+    @Override
+    public void close() {
+        closed = true;
+    }
+
+    /** Set the output to write to.
+     *
+     * @param output the output to set */
+    public synchronized void connect(final PrintStream output) {
+        out = output;
+        while (!messages.isEmpty()) {
+            output.print(messages.pop());
+        }
+    }
+
+    /** Disconnects the output. */
+    public synchronized void disconnect() {
+        out = null;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleOutput#isClosed() */
+    @Override
+    public boolean isClosed() {
+        return closed;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleOutput#print(java.lang.String) */
+    @Override
+    public synchronized void print(final String text) throws IOException {
+        if (closed) {
+            throw new IOException("Closed output"); //$NON-NLS-1$
+        }
+        if (out == null) {
+            messages.add(text);
+        } else {
+            out.print(text);
+        }
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleOutput#println() */
+    @Override
+    public synchronized void println() throws IOException {
+        if (closed) {
+            throw new IOException("Closed output"); //$NON-NLS-1$
+        }
+        if (out == null) {
+            messages.add("\n"); //$NON-NLS-1$
+        } else {
+            out.println();
+        }
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleOutput#println(java.lang.String) */
+    @Override
+    public synchronized void println(final String message) throws IOException {
+        print(message);
+        println();
+    }
+
+}

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

@@ -0,0 +1,132 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.RemoteDisconnectCommand.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import java.io.IOException;
+import java.text.MessageFormat;
+import java.util.Collection;
+
+import fr.bigeon.gclc.command.Command;
+import fr.bigeon.gclc.exception.CommandRunException;
+import fr.bigeon.gclc.exception.CommandRunExceptionType;
+import fr.bigeon.gclc.manager.ConsoleInput;
+import fr.bigeon.gclc.manager.ConsoleOutput;
+
+/** A {@link Command} to disconnect elements from a {@link ConnexionManager}.
+ *
+ * @author Emmanuel Bigeon
+ * @param <T> the type of connected object */
+public final class RemoteDisconnectCommand<T> extends Command {
+
+    /** The connexion manager. */
+    private final ConnexionManager<T> manager;
+    /** If all connexion should be disconnected when no argument have been
+     * specified. */
+    private final boolean all;
+
+    /** Create the disconnection command.
+     *
+     * @param name the command name
+     * @param manager the manager
+     * @param all if all elements should be disconnected when no argument is
+     *            provided */
+    public RemoteDisconnectCommand(final String name,
+            final ConnexionManager<T> manager, final boolean all) {
+        super(name);
+        this.manager = manager;
+        this.all = all;
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.manager.
+     * ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput,
+     * java.lang.String[]) */
+    @Override
+    public void execute(final ConsoleOutput out, final ConsoleInput in,
+                        final String... args) throws CommandRunException {
+        if (args.length == 0 && all) {
+            final Collection<String> coll = manager.getConnected();
+            for (final String string : coll) {
+                manager.disconnect(string);
+            }
+        }
+        for (final String string : args) {
+            if (manager.isConnected(string)) {
+                manager.disconnect(string);
+            } else {
+                print(out, MessageFormat
+                        .format("[WARNING] {0} is not connected", string)); //$NON-NLS-1$
+            }
+        }
+    }
+
+    /** Print a message if the output is defined.
+     *
+     * @param out the output
+     * @param string the message
+     * @throws CommandRunException if the output exists but cannot be printed
+     *             to */
+    private void print(final ConsoleOutput out,
+                       final String string) throws CommandRunException {
+        if (out != null) {
+            try {
+                out.println(string);
+            } catch (final IOException e) {
+                throw new CommandRunException(
+                        CommandRunExceptionType.INTERACTION,
+                        "Unable to print to existing output", e, this); //$NON-NLS-1$
+            }
+        }
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.command.ICommand#tip() */
+    @Override
+    public String tip() {
+        return "Close a connexion."; //$NON-NLS-1$
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.command.Command#usageDetail() */
+    @SuppressWarnings("nls")
+    @Override
+    protected String usageDetail() {
+        return MessageFormat.format(
+                "  If arguments are provided the corresponding connexions are closed, " +
+                                    "otherwise{0}{1} are.",
+                System.lineSeparator(), all ? "all connexions" : "none");
+    }
+}

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2014)
+ * GCLC Socket, Socket implementation of GCLC
- *
+ * Copyright (C) 2014-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto:emmanuel@bigeon.fr
- *
- * This software is a computer program whose purpose is to
- * Socket implementation of GCLC.
  *
  * This software is governed by the CeCILL license under French law and
  * abiding by the rules of distribution of free software.  You can  use,
@@ -34,24 +31,17 @@
  */
 package fr.bigeon.gclc.socket;
 
-import java.io.BufferedReader;
 import java.io.IOException;
-import java.io.InputStreamReader;
+import java.net.InetAddress;
-import java.io.OutputStreamWriter;
-import java.io.PrintWriter;
 import java.net.ServerSocket;
 import java.net.Socket;
 import java.net.SocketException;
-import java.nio.charset.Charset;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
 import fr.bigeon.gclc.ConsoleApplication;
-import fr.bigeon.gclc.manager.PipedConsoleInput;
-import fr.bigeon.gclc.manager.PipedConsoleOutput;
-import fr.bigeon.gclc.manager.ReadingRunnable;
 
-/** This is a socket communicating console consoleManager
+/** This is a socket communicating console consoleManager.
  * <p>
  * To use this application, the following flow should be used:
  *
@@ -69,238 +59,60 @@ import fr.bigeon.gclc.manager.ReadingRunnable;
  * end of the execution.
  *
  * @author Emmanuel Bigeon */
-public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
+public final class SocketConsoleApplicationShell implements Runnable {
 
-    /** The runnable to forward output of application to socket.
+    /** The class logger. */
-     *
-     * @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(final PrintWriter writer, final Socket socket) {
-            this.writer = writer;
-            this.socket = socket;
-        }
-
-        @SuppressWarnings("synthetic-access")
-        @Override
-        public void run() {
-            try {
-                while (!socket.isClosed()) {
-                    while (!socket.isClosed() && !output.available()) {
-                        waitASec();
-                    }
-                    if (socket.isClosed()) {
-                        return;
-                    }
-                    final String m = output.readNextLine();
-                    writer.println(m);
-                }
-            } catch (final IOException e) {
-                LOGGER.log(Level.SEVERE, "Unexpected problem in manager", //$NON-NLS-1$
-                        e);
-            }
-        }
-
-    }
-
-    /** The end of line character */
-    protected static final String EOL = "\n"; //$NON-NLS-1$
-    /** The class logger */
     private static final Logger LOGGER = Logger
             .getLogger(SocketConsoleApplicationShell.class.getName());
-    /** Time of wait */
+    /** The listening port. */
-    protected static final long ONE_TENTH_OF_SECOND = 100;
-    /** The listening port */
     private final int port;
-    /** The application */
+    /** The running status. */
-    private ConsoleApplication app;
-    /** The session closing command */
-    private final String close;
-    /** The running status */
     private boolean running;
+    /** The socket console interface. */
+    private SocketConsoleInterface sci;
+    /** The remote disconnection command. */
+    private ConnexionManager<Socket> rdc;
+    /** The application. */
+    private ConsoleApplication app;
 
-    /** The auto close flag. if this is true, every request closes the session
+    /** The server socket. */
-     * after its call */
-    private final boolean autoClose;
-    /** The server socket */
     private ServerSocket serverSocket;
-    /** The application shutdown string */
+    /** THe server address. */
-    private final String applicationShutdown;
+    private final InetAddress addr;
-    /** The charset for the communication. */
-    private final Charset charset;
-    private final PipedConsoleOutput output;
-    private final PipedConsoleInput input;
 
     /** Create a socket application shell which will listen on the given port
-     * and auto close session after one instruction
+     * and network interface.
      *
-     * @param port the port to listen to
+     * @param port the part
-     * @param autoClose if the session must be closed once the request has been
+     * @param addr the inet address */
-     *            sent
+    public SocketConsoleApplicationShell(final int port,
-     * @param applicationShutdown the appication shut down command
+            final InetAddress addr) {
-     * @param charset the charset for communication
+        super();
-     * @throws IOException if the manager could not be created */
-    public SocketConsoleApplicationShell(final int port, final boolean autoClose,
-            final String applicationShutdown, final Charset charset) throws IOException {
         this.port = port;
-        this.autoClose = autoClose;
+        this.addr = addr;
-        this.applicationShutdown = applicationShutdown;
-        close = autoClose ? null : "close"; //$NON-NLS-1$
-        this.charset = charset;
-        //
-        output = new PipedConsoleOutput();
-        input = new PipedConsoleInput();
     }
 
-    /** Create a socket application shell which will listen on the given port
+    /** Wait for the identified connection to disconnect.
-     * and close session upon the provided string reception by client
      *
-     * @param port the port to listen to
+     * @param id the connexion id. */
-     * @param close the session closing command
+    private void awaitDisconnexion(final String id) {
-     * @param applicationShutdown the appication shut down command
+        while (rdc.isConnected(id)) {
-     * @param charset the charset for communication
-     * @throws IOException if the manager could not be created */
-    public SocketConsoleApplicationShell(final int port, final String close,
-            final String applicationShutdown, final Charset charset) throws IOException {
-        this.port = port;
-        this.close = close;
-        this.applicationShutdown = applicationShutdown;
-        autoClose = false;
-        this.charset = charset;
-        //
-        output = new PipedConsoleOutput();
-        input = new PipedConsoleInput();
-    }
-
-    /* (non-Javadoc)
-     * @see java.lang.AutoCloseable#close() */
-    @Override
-    public void close() throws IOException {
-        input.close();
-        output.close();
-    }
-
-    /** Close the console manager after writing the application shutdown
-     * command.
-     *
-     * @param appThNext the thread containing the application
-     * @throws IOException if the typyng or closing failed */
-    private void closeManager(final Thread appThNext) throws IOException {
-        input.type(applicationShutdown);
             try {
-            appThNext.join(ONE_TENTH_OF_SECOND);
+                rdc.waitDisconnexion(id);
             } catch (final InterruptedException e) {
-            LOGGER.warning("Application thread was interrupted!"); //$NON-NLS-1$
+                LOGGER.log(Level.SEVERE, "Unexpected interruption", e); //$NON-NLS-1$
-            LOGGER.log(Level.FINE,
+                Thread.currentThread().interrupt();
-                    "Application thread was interrupted while closing", //$NON-NLS-1$
-                    e);
             }
-        close();
+        }
+        sci.disconnect();
     }
 
-    /** active communication between server and client
+    /** If the port provided was 0, this allows to get the actual port.
-     *
+     * @return the local port
-     * @param socket the socket
+     * @see java.net.ServerSocket#getLocalPort()
-     * @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,
-                             final BufferedReader in) throws IOException {
-        final OutputForwardRunnable cc = new OutputForwardRunnable(writer, socket);
-        final Thread th = new Thread(cc, "ClientComm"); //$NON-NLS-1$
-        th.start();
-        if (autoClose) {
-            communicateOnce(in);
-        } else {
-            communicateLoop(in);
-        }
-    }
-
-    /** @param in the input from the client
-     * @throws IOException if the communication failed */
-    private void communicateLoop(final BufferedReader in) throws IOException {
-        final ReadingRunnable reading = new ReadingRunnable(in);
-        final Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
-        th.start();
-        while (app.isRunning() && communicationContent(reading)) {
-            // keep on going
-        }
-        doEndCommunication(reading);
-    }
-
-    /** @param in the input from the client
-     * @throws IOException if the communication failed */
-    private void communicateOnce(final BufferedReader in) throws IOException {
-        final ReadingRunnable reading = new ReadingRunnable(in);
-        final Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
-        th.start();
-        communicationContent(reading);
-        doEndCommunication(reading);
-    }
-
-    /** @param reading the reading
-     * @return if the communication should be stopped.
-     * @throws IOException if the reading failed */
-    private boolean communicationContent(final ReadingRunnable reading) throws IOException {
-        try {
-            while (app.isRunning() && !reading.hasMessage()) {
-                synchronized (this) {
-                    waitASec();
-                }
-            }
-        } catch (final 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;
-        }
-        final String ln = reading.getMessage();
-        if (ln.equals(close)) {
-            return false;
-        }
-        // Pass command to application
-        input.type(ln);
-        return true;
-    }
-
-    /** @param reading the reading runnable
-     * @throws IOException if the end of communication failed */
-    private void doEndCommunication(final ReadingRunnable reading) throws IOException {
-        reading.setRunning(false);
-        final Thread wait = output.getWaitForDelivery("Bye."); //$NON-NLS-1$
-        output.println("Bye."); //$NON-NLS-1$
-        try {
-            wait.join();
-        } catch (final InterruptedException e) {
-            LOGGER.warning("The Bye wait was interrupted."); //$NON-NLS-1$
-            LOGGER.log(Level.FINE, "An interruption occured", e); //$NON-NLS-1$
-        }
-    }
-
-    /**
-     * @return the input
      */
-    public PipedConsoleInput getInput() {
+    public int getLocalPort() {
-        return input;
+        return serverSocket.getLocalPort();
-    }
-
-    /**
-     * @return the output
-     */
-    public PipedConsoleOutput getOutput() {
-        return output;
     }
 
     /* (non-Javadoc)
@@ -308,7 +120,8 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
     @Override
     public void run() {
         // Create the server
-        try (ServerSocket actualServerSocket = new ServerSocket(port)) {
+        try (ServerSocket actualServerSocket = new ServerSocket(port, 1,
+                addr)) {
             serverSocket = actualServerSocket;
             running = true;
             // Create the streams
@@ -320,33 +133,20 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
         }
     }
 
-    /** @throws IOException if the communication with the client failed */
+    /** Acctually run the server loop on connexion.
+     *
+     * @throws IOException if the communication with the client failed */
     private void runSokectServer() throws IOException {
-        final ConsoleRunnable runnable = new ConsoleRunnable(app);
+        while (running && app.isRunning()) {
-        final Thread appThNext = new Thread(runnable, "gclc-ctrl"); //$NON-NLS-1$
-        appThNext.start();
-        while (running) {
             LOGGER.info("Waiting client"); //$NON-NLS-1$
-            try (Socket clientSocket = serverSocket.accept();
+            try (Socket clientSocket = serverSocket.accept();) {
-                 PrintWriter out = new PrintWriter(new OutputStreamWriter(
-                         clientSocket.getOutputStream(), charset), true);
-                 InputStreamReader isr = new InputStreamReader(
-                         clientSocket.getInputStream(), charset);
-                 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
+                sci.connect(clientSocket);
-                if (!runnable.isApplicationRunning()) {
+
-                    LOGGER.info("Start application"); //$NON-NLS-1$
+                final String id = rdc.addConnexion(clientSocket);
-                    startApplication(runnable);
+                rdc.lockDisconnexion(id);
-                } else {
+                awaitDisconnexion(id);
-                    LOGGER.info("Reconnect to application"); //$NON-NLS-1$
+                rdc.releaseDisconnexionLock(id);
-                    out.println("Reconnected"); //$NON-NLS-1$
-                    out.println(input.getPrompt());
-                }
-                communicate(clientSocket, out, in);
             } catch (final SocketException e) {
                 LOGGER.log(Level.INFO, "Socket closed"); //$NON-NLS-1$
                 LOGGER.log(Level.FINE,
@@ -357,33 +157,30 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
             }
             LOGGER.info("Closing client"); //$NON-NLS-1$
         }
-        runnable.setRunning(false);
-        try {
-            closeManager(appThNext);
-        } catch (final IOException e) {
-            LOGGER.warning("Unable to close application correctly"); //$NON-NLS-1$
-            LOGGER.log(Level.FINE, "Application closing caused an exception", //$NON-NLS-1$
-                    e);
-        }
         LOGGER.info("Closing Server"); //$NON-NLS-1$
     }
 
-    /** @param app the application to set */
+    /** Set the application.
-    public synchronized void setApplication(final ConsoleApplication app) {
+     * <p>
+     * If the application is closed, the server will also close.
+     *
+     * @param app the app to set */
+    public void setApplication(final ConsoleApplication app) {
         this.app = app;
     }
 
-    /** @param runnable the runnable */
+    /** Set the connexion manager.
-    private void startApplication(final ConsoleRunnable runnable) {
+     *
-        runnable.restart();
+     * @param rdc the rdc to set */
-        synchronized (this) {
+    public void setConnexionManager(final ConnexionManager<Socket> rdc) {
-            try {
+        this.rdc = rdc;
-                wait(ONE_TENTH_OF_SECOND);
-            } catch (final InterruptedException e) {
-                LOGGER.log(Level.SEVERE, "Interruption in application start", //$NON-NLS-1$
-                        e);
-            }
     }
+
+    /** Set the socket console interface.
+     *
+     * @param sci the console interface to set */
+    public void setInterface(final SocketConsoleInterface sci) {
+        this.sci = sci;
     }
 
     /** This method will request the server to stop.
@@ -397,19 +194,5 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
         } catch (final IOException e) {
             LOGGER.log(Level.SEVERE, "Exception in closing socket server", e); //$NON-NLS-1$
         }
-        app.exit();
-    }
-
-    /** a method to wait some time */
-    protected void waitASec() {
-        try {
-            synchronized (this) {
-                wait(ONE_TENTH_OF_SECOND);
-            }
-        } catch (final InterruptedException e) {
-            LOGGER.log(Level.SEVERE, "Interrupted wait", //$NON-NLS-1$
-                    e);
-            return;
-        }
     }
 }

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

@@ -0,0 +1,82 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.SocketConsoleInterface.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import java.io.IOException;
+import java.io.PrintStream;
+import java.net.Socket;
+import java.nio.charset.StandardCharsets;
+
+/** The interface for socket based access to console application.
+ *
+ * @author Emmanuel Bigeon */
+public final class SocketConsoleInterface {
+
+    /** The application's input. */
+    private final PluggableConsoleInput input;
+    /** The application's output. */
+    private final PluggableConsoleOutput output;
+
+    /** Create the interfacing object.
+     *
+     * @param input the input
+     * @param output the output */
+    public SocketConsoleInterface(final PluggableConsoleInput input,
+            final PluggableConsoleOutput output) {
+        super();
+        this.input = input;
+        this.output = output;
+    }
+
+    /** Connect the application's input and outputs to the socket's.
+     *
+     * @param socket the socket
+     * @throws IOException if the connection failed */
+    public void connect(final Socket socket) throws IOException {
+        final PrintStream printStream = new PrintStream(
+                socket.getOutputStream(), true,
+                StandardCharsets.UTF_8.name());
+        output.connect(printStream);
+        input.connect(socket.getInputStream(),
+                printStream);
+    }
+
+    /** Disconnect the input and output of the application from the socket's. */
+    public void disconnect() {
+        input.disconnect();
+        output.disconnect();
+    }
+}

gclc-socket/src/main/java/fr/bigeon/gclc/socket/package-info.java

@@ -0,0 +1,40 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.package-info.java
+ * Created on: Nov 18, 2017
+ */
+/** This package define a framework to access
+ * {@link fr.bigeon.gclc.ConsoleApplication} through a socket.
+ *
+ * @author Emmanuel Bigeon */
+package fr.bigeon.gclc.socket;

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

@@ -1,182 +0,0 @@
-/*
- * Copyright E. Bigeon (2014)
- *
- * emmanuel@bigeon.fr
- *
- * This software is a computer program whose purpose is to
- * Socket implementation of GCLC.
- *
- * 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-socket:fr.bigeon.gclc.socket.ConsoleRunnableTest.java
- * Created on: Jun 1, 2016
- */
-package fr.bigeon.gclc.socket;
-
-import java.io.IOException;
-
-import org.junit.Test;
-
-import fr.bigeon.gclc.manager.ConsoleInput;
-
-/** Test class for {@link ConsoleRunnable}
- *
- * @author Emmanuel Bigeon */
-@SuppressWarnings({"unused", "javadoc"})
-public class ConsoleRunnableTest {
-
-    /** <p>
-     * TODO
-     *
-     * @author Emmanuel Bigeon */
-    private static final class ConsoleManagerTestImplementation
-            implements ConsoleInput {
-        int i = 0;
-        String[] cmds;
-
-        /** @param cmds the commands to run */
-        public ConsoleManagerTestImplementation(final String[] cmds) {
-            super();
-            this.cmds = cmds;
-        }
-
-        @Override
-        public void close() throws IOException {
-            // do nothing
-        }
-
-        @Override
-        public String getPrompt() {
-            // Not used in test
-            return ""; //$NON-NLS-1$
-        }
-
-        /* (non-Javadoc)
-         * @see fr.bigeon.gclc.manager.ConsoleManager#interruptPrompt() */
-        @Override
-        public void interruptPrompt() {
-            //
-        }
-
-        /* (non-Javadoc)
-         * @see fr.bigeon.gclc.manager.ConsoleManager#isClosed() */
-        @Override
-        public boolean isClosed() {
-            return i == cmds.length;
-        }
-
-        @Override
-        public String prompt() {
-            try {
-                Thread.sleep(1000);
-            } catch (final InterruptedException e) { // NOSONAR
-                // do nothing
-            }
-            i++;
-            if (i == cmds.length) {
-                i = 0;
-            }
-            return cmds[i];
-        }
-
-        /* (non-Javadoc)
-         * @see fr.bigeon.gclc.manager.ConsoleManager#prompt(long) */
-        @Override
-        public String prompt(final long timeout) throws IOException {
-            return prompt();
-        }
-
-        @Override
-        public String prompt(final String message) {
-            return prompt();
-        }
-
-        /* (non-Javadoc)
-         * @see fr.bigeon.gclc.manager.ConsoleManager#prompt(java.lang.String,
-         * long) */
-        @Override
-        public String prompt(final String message, final long timeout) throws IOException {
-            return prompt(message);
-        }
-
-        @Override
-        public void setPrompt(final String prompt) {
-            // do nothing
-        }
-    }
-
-    /** Test method for
-     * {@link fr.bigeon.gclc.socket.ConsoleRunnable#ConsoleRunnable(fr.bigeon.gclc.ConsoleApplication)}
-     * . */
-    @Test
-    public void testConsoleRunnable() {
-//        ConsoleApplication app = new ConsoleTestApplication(
-//                new SystemConsoleManager());
-//        ConsoleRunnable runnable = new ConsoleRunnable(app);
-
-    }
-
-    /** 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();
-    }
-
-    /** 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();
-    }
-
-    /** 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();
-    }
-
-}

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2014)
+ * GCLC Socket, Socket implementation of GCLC
- *
+ * Copyright (C) 2014-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto:emmanuel@bigeon.fr
- *
- * This software is a computer program whose purpose is to
- * Socket implementation of GCLC.
  *
  * This software is governed by the CeCILL license under French law and
  * abiding by the rules of distribution of free software.  You can  use,
@@ -35,6 +32,8 @@
 package fr.bigeon.gclc.socket;
 
 import java.io.IOException;
+import java.net.Socket;
+import java.util.Collection;
 
 import fr.bigeon.gclc.ConsoleApplication;
 import fr.bigeon.gclc.command.Command;
@@ -53,17 +52,32 @@ public class ConsoleTestApplication {
     /** Exit command */
     public static final String EXIT = "exit"; //$NON-NLS-1$
 
-    /** @param manager the manager
+    /** Create the test application.
+     * 
+     * @param output the output
+     * @param input the input
+     * @param manager the manager
      * @return create the application */
     @SuppressWarnings("nls")
-    public static ConsoleApplication create(final ConsoleOutput manager,
+    public static ConsoleApplication create(final ConsoleOutput output,
-                                            final ConsoleInput input) {
+                                            final ConsoleInput input,
+                                            final ConnexionManager<Socket> manager) {
         try {
             final ConsoleApplication application = new ConsoleApplication(
-                    manager, input,
+                    output, input,
                     "Welcome to the test application. Type help or test.",
                     "See you");
-            application.add(new ExitCommand(EXIT, application));
+            application.add(new ExitCommand(EXIT, application) {
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.ExitCommand#beforeExit() */
+                @Override
+                protected void beforeExit() {
+                    final Collection<String> coll = manager.getConnected();
+                    for (final String string : coll) {
+                        manager.disconnect(string);
+                    }
+                }
+            });
             application
                     .add(new HelpExecutor("help", application.root));
             application.add(new Command("test") {
@@ -77,7 +91,7 @@ public class ConsoleTestApplication {
                                     final ConsoleInput in,
                                     final String... args) throws CommandRunException {
                     try {
-                        manager.println("Test command ran fine");
+                        output.println("Test command ran fine");
                     } catch (final IOException e) {
                         throw new CommandRunException("manager closed", e,
                                 this);
@@ -111,7 +125,7 @@ public class ConsoleTestApplication {
                                     final String... args) throws CommandRunException {
                     try {
                         Thread.sleep(2000);
-                        manager.println("Test command ran fine");
+                        output.println("Test command ran fine");
                     } catch (IOException | InterruptedException e) {
                         throw new CommandRunException("manager closed", e,
                                 this);
@@ -133,6 +147,8 @@ public class ConsoleTestApplication {
                     throw new RuntimeException("Not implemented yet");
                 }
             });
+            application.add(
+                    new RemoteDisconnectCommand<>("out", manager, true));
             return application;
         } catch (final InvalidCommandName e) {
             e.printStackTrace();

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

@@ -0,0 +1,200 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.PluggableConsoleInputTest.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
+import java.io.IOException;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.io.PrintStream;
+
+import org.junit.Test;
+
+/**
+ * <p>
+ * TODO
+ *
+ * @author Emmanuel Bigeon */
+public class PluggableConsoleInputTest {
+
+    /** Test method for
+     * {@link fr.bigeon.gclc.socket.PluggableConsoleInput#close()}. */
+    @Test
+    public final void testClose() {
+        final PluggableConsoleInput input = new PluggableConsoleInput();
+        assertFalse("Input should not be initially closed", input.isClosed());
+        input.close();
+        assertTrue("Close should close the input", input.isClosed());
+
+        try {
+            input.prompt();
+            fail("Closed prompt should cause an IO");
+        } catch (final IOException e) {
+            // ok
+        }
+        try {
+            input.prompt(10);
+            fail("Closed prompt should cause an IO");
+        } catch (final IOException e) {
+            // ok
+        }
+
+        final PluggableConsoleInput input2 = new PluggableConsoleInput();
+
+        final Thread th = new Thread(new Runnable() {
+
+            @Override
+            public void run() {
+                while (!input2.isPrompting()) {
+
+                }
+                try {
+                    Thread.sleep(100);
+                } catch (final InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                input2.close();
+            }
+        });
+        th.start();
+        try {
+            input.prompt();
+            fail("Closed prompt should cause an IO");
+        } catch (final IOException e) {
+            // ok
+        }
+        final PluggableConsoleInput input3 = new PluggableConsoleInput();
+
+        final Thread th2 = new Thread(new Runnable() {
+
+            @Override
+            public void run() {
+                try {
+                    Thread.sleep(200);
+                } catch (final InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                input3.close();
+            }
+        });
+        th2.start();
+        try {
+            input.prompt(2000);
+            fail("Closed prompt should cause an IO");
+        } catch (final IOException e) {
+            // ok
+        }
+    }
+
+    @Test
+    public final void testConnect() throws IOException, InterruptedException {
+        final PluggableConsoleInput input = new PluggableConsoleInput();
+
+        input.disconnect();
+        try (final PipedInputStream pis = new PipedInputStream();
+             final PipedOutputStream pos = new PipedOutputStream();
+             final PipedInputStream inner = new PipedInputStream(pos);
+             final PipedOutputStream innerPos = new PipedOutputStream(pis);
+             final PrintStream testIn = new PrintStream(innerPos, true, "UTF8");
+             final PrintStream out = new PrintStream(pos)) {
+            input.connect(pis, out);
+            try {
+                input.connect(pis, out);
+                fail("Should not be able to connect already connected");
+            } catch (final IOException e) {
+                // ok
+            }
+            input.disconnect();
+
+            final Thread th = new Thread(new Runnable() {
+
+                @Override
+                public void run() {
+                    try {
+                        input.prompt("Test", 5000);
+                    } catch (final IOException e) {
+                        e.printStackTrace();
+                    }
+                }
+            });
+            th.start();
+
+            while (!input.isPrompting()) {
+                Thread.sleep(10);
+            }
+
+            input.connect(pis, out);
+            testIn.println("tac");
+
+            final Thread th2 = new Thread(new Runnable() {
+
+                @Override
+                public void run() {
+                    try {
+                        input.prompt("Test", 5000);
+                        fail("Prompt should io");
+                    } catch (final IOException e) {
+                        // ok
+                    }
+                }
+            });
+            th2.start();
+            while (!input.isPrompting()) {
+                Thread.sleep(10);
+            }
+
+            input.close();
+
+
+        }
+    }
+
+    /** Test method for
+     * {@link fr.bigeon.gclc.socket.PluggableConsoleInput#getPrompt()}. */
+    @Test
+    public final void testGetPrompt() {
+        final PluggableConsoleInput input = new PluggableConsoleInput();
+        assertEquals("Default prompt invalid", "> ", input.getPrompt());
+        input.setPrompt("test");
+        assertEquals("Prompt setting failed", "test", input.getPrompt());
+    }
+}

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

@@ -0,0 +1,105 @@
+/*
+ * GCLC Socket, Socket implementation of GCLC
+ * Copyright (C) 2014-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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-socket:fr.bigeon.gclc.socket.RemoteDisconnectCommandTest.java
+ * Created on: Nov 18, 2017
+ */
+package fr.bigeon.gclc.socket;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
+import java.io.IOException;
+
+import org.junit.Test;
+
+import fr.bigeon.gclc.exception.CommandRunException;
+import fr.bigeon.gclc.manager.PipedConsoleOutput;
+
+/**
+ * <p>
+ * TODO
+ *
+ * @author Emmanuel Bigeon */
+public class RemoteDisconnectCommandTest {
+
+    /** Test method for
+     * {@link fr.bigeon.gclc.socket.RemoteDisconnectCommand#execute(fr.bigeon.gclc.manager.ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput, java.lang.String[])}.
+     *
+     * @throws CommandRunException if the command unexpectedly failed.
+     * @throws IOException if the output could not be written to */
+    @Test
+    public final void testExecute() throws CommandRunException, IOException {
+        final DConnexionManager<String> manager = new DConnexionManager<>();
+        final RemoteDisconnectCommand<String> cmd = new RemoteDisconnectCommand<>(
+                "quit", manager, true);
+        final RemoteDisconnectCommand<String> cmd2 = new RemoteDisconnectCommand<>(
+                "quit", manager, false);
+        manager.addConnexion("test");
+
+        cmd2.execute(null, null);
+        assertFalse("No arguemnt should remova no connections",
+                manager.getConnected().isEmpty());
+        cmd.execute(null, null);
+        assertTrue("No arguemnt should remova all connections",
+                manager.getConnected().isEmpty());
+
+        final String name1 = manager.addConnexion("test");
+        final String name2 = manager.addConnexion("test");
+
+        cmd.execute(null, null, name1);
+        assertFalse("With argument shuld remove specified name",
+                manager.getConnected().contains(name1));
+        assertTrue("With argument shuld remove only specified name",
+                manager.getConnected().contains(name2));
+
+        cmd.execute(null, null, name1);
+        assertTrue("With argument shuld remove only specified name",
+                manager.getConnected().contains(name2));
+
+        try (PipedConsoleOutput out = new PipedConsoleOutput()) {
+            cmd.execute(out, null, name1);
+            assertTrue("With argument shuld remove only specified name",
+                    manager.getConnected().contains(name2));
+
+            out.close();
+            try {
+                cmd.execute(out, null, name1);
+                fail("Closed stream should cause error in printing");
+            } catch (final CommandRunException e) {
+                // ok
+            }
+        }
+    }
+
+}

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2014)
+ * GCLC Socket, Socket implementation of GCLC
- *
+ * Copyright (C) 2014-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto:emmanuel@bigeon.fr
- *
- * This software is a computer program whose purpose is to
- * Socket implementation of GCLC.
  *
  * This software is governed by the CeCILL license under French law and
  * abiding by the rules of distribution of free software.  You can  use,
@@ -39,9 +36,6 @@
 package fr.bigeon.gclc.socket;
 
 import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -55,26 +49,32 @@ import org.junit.Test;
 /** Test class for {@link SocketConsoleApplicationShell}
  *
  * @author Emmanuel Bigeon */
-@SuppressWarnings({"static-method", "unused", "javadoc", "nls"})
+@SuppressWarnings({"static-method", "javadoc", "nls"})
 public class SocketConsoleApplicationTest {
 
     private static final Logger LOGGER = Logger
             .getLogger(SocketConsoleApplicationTest.class.getName());
 
+    /** @param in the input
+     * @return the string
+     * @throws IOException if the input reading failed */
+    private String consumeToPrompt(final String server,
+                                   final BufferedReader in) throws IOException {
+        String fromServer = server;
+        LOGGER.fine("Server: \n" + fromServer);
+        while (fromServer != null && !fromServer.equals("Bye.") &&
+               !fromServer.equals("> ")) {
+            fromServer = in.readLine();
+            LOGGER.fine("Server: \n" + fromServer);
+        }
+        return fromServer;
+    }
+
     @Test
-    public void integrationTest() {
+    public void testIntegration() throws IOException, InterruptedException {
         Thread server;
-        try {
+        server = TestServer.getServer();
-            server = TestServer.startServer("bye");
-        } catch (IOException e3) {
-            assertNull(e3);
-            fail("unable to start server");
-        }
-        try {
         Thread.sleep(1000);
-        } catch (InterruptedException e1) {
-            e1.printStackTrace();
-        }
         final String hostName = "127.0.0.1";
         final int portNumber = 3300;
 
@@ -86,7 +86,7 @@ public class SocketConsoleApplicationTest {
 
             String fromServer;
             int i = -1;
-            String[] cmds = {"help", "toto", "test", "bye"};
+            final String[] cmds = {"help", "toto", "test", "out"};
             while ((fromServer = in.readLine()) != null) {
                 i++;
                 fromServer = consumeToPrompt(fromServer, in);
@@ -100,9 +100,7 @@ public class SocketConsoleApplicationTest {
                     out.println(fromUser);
                 }
             }
-            assertEquals(4, i);
+            assertEquals("Disconnection command should close connection", 3, i);
-        } catch (final IOException e) {
-            e.printStackTrace();
         }
 
         try (Socket kkSocket = new Socket(hostName, portNumber);
@@ -113,7 +111,7 @@ public class SocketConsoleApplicationTest {
 
             String fromServer;
             int i = 0;
-            String[] cmds = {"help", "toto", "test",
+            final String[] cmds = {"help", "toto", "test",
                     ConsoleTestApplication.EXIT};
             while ((fromServer = in.readLine()) != null) {
                 fromServer = consumeToPrompt(fromServer, in);
@@ -129,15 +127,15 @@ public class SocketConsoleApplicationTest {
                 }
                 i++;
             }
-            assertEquals(4, i);
+            assertEquals("Application exit command should close connection", 4,
-        } catch (final IOException e) {
+                    i);
-            e.printStackTrace();
         }
-        try {
         Thread.sleep(100);
-        } catch (InterruptedException e1) {
+        TestServer.closeServer();
-            e1.printStackTrace();
+        server.join();
-        }
+        server = TestServer.getServer();
+        Thread.sleep(1000);
+
 
         try (Socket kkSocket = new Socket(hostName, portNumber);
              PrintWriter out = new PrintWriter(kkSocket.getOutputStream(),
@@ -147,7 +145,7 @@ public class SocketConsoleApplicationTest {
 
             String fromServer;
             int i = 0;
-            String[] cmds = {"help", "toto", "test",
+            final String[] cmds = {"help", "toto", "test",
                     ConsoleTestApplication.EXIT};
             while ((fromServer = in.readLine()) != null) {
                 fromServer = consumeToPrompt(fromServer, in);
@@ -162,80 +160,10 @@ public class SocketConsoleApplicationTest {
                 }
                 i++;
             }
-            assertEquals(4, i);
+            assertEquals("Application exit command should close connection", 4,
-        } catch (final IOException e) {
+                    i);
-            e.printStackTrace();
         }
         TestServer.closeServer();
-        try {
+        server.join();
-            Thread.sleep(100);
-        } catch (InterruptedException e2) {
-            e2.printStackTrace();
-        }
-        try {
-            server = TestServer.startServer(true);
-        } catch (IOException e2) {
-            assertNull(e2);
-        }
-        try {
-            Thread.sleep(100);
-        } catch (InterruptedException e1) {
-            e1.printStackTrace();
-        }
-
-        try (Socket kkSocket = new Socket(hostName, portNumber);
-             PrintWriter out = new PrintWriter(kkSocket.getOutputStream(),
-                     true);
-             BufferedReader in = new BufferedReader(
-                     new InputStreamReader(kkSocket.getInputStream()));) {
-
-            String fromServer;
-            int i = 0;
-            String[] cmds = {"help", "test", "close"};
-            while ((fromServer = in.readLine()) != null) {
-                fromServer = consumeToPrompt(fromServer, in);
-                if (fromServer == null || fromServer.equals("Bye.")) {
-                    break;
-                }
-                assertTrue(i < 1);
-                final String fromUser = cmds[i];
-                if (fromUser != null) {
-                    LOGGER.fine("Client: " + fromUser);
-                    out.println(fromUser);
-                }
-                i++;
-            }
-            assertEquals(1, i);
-        } catch (final IOException e) {
-            e.printStackTrace();
-        }
-        Thread srv = null;
-        try {
-            srv = TestServer.getServer();
-        } catch (IOException e1) {
-            assertNull(e1);
-        }
-        TestServer.closeServer();
-        try {
-            srv.join();
-        } catch (InterruptedException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        }
-    }
-
-    /** @param in the input
-     * @return the string
-     * @throws IOException if the input reading failed */
-    private String consumeToPrompt(String server,
-                                   BufferedReader in) throws IOException {
-        String fromServer = server;
-        LOGGER.fine("Server: \n" + fromServer);
-        while (fromServer != null && !fromServer.equals("Bye.") &&
-               !fromServer.equals("> ")) {
-            fromServer = in.readLine();
-            LOGGER.fine("Server: \n" + fromServer);
-        }
-        return fromServer;
     }
 }

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2014)
+ * GCLC Socket, Socket implementation of GCLC
- *
+ * Copyright (C) 2014-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto:emmanuel@bigeon.fr
- *
- * This software is a computer program whose purpose is to
- * Socket implementation of GCLC.
  *
  * This software is governed by the CeCILL license under French law and
  * abiding by the rules of distribution of free software.  You can  use,

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2014)
+ * GCLC Socket, Socket implementation of GCLC
- *
+ * Copyright (C) 2014-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto:emmanuel@bigeon.fr
- *
- * This software is a computer program whose purpose is to
- * Socket implementation of GCLC.
  *
  * This software is governed by the CeCILL license under French law and
  * abiding by the rules of distribution of free software.  You can  use,
@@ -35,7 +32,9 @@
 package fr.bigeon.gclc.socket;
 
 import java.io.IOException;
-import java.nio.charset.Charset;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
 
 import fr.bigeon.gclc.ConsoleApplication;
 
@@ -46,14 +45,21 @@ import fr.bigeon.gclc.ConsoleApplication;
 public class TestServer {
 
     private static SocketConsoleApplicationShell SHELL;
-    private static Thread server;
+    private static ConnexionManager<Socket> manager;
 
-    public static void closeServer() {
+    private static Thread server;
+    private static PluggableConsoleInput input;
+    private static PluggableConsoleOutput output;
+
+    public static synchronized void closeServer() {
         SHELL.stop();
+        input.close();
+        output.close();
         SHELL = null;
+        server = null;
     }
 
-    public static Thread getServer() throws IOException {
+    public static synchronized Thread getServer() throws IOException {
         if (server == null) {
             server = new Thread(getShell(), "gclcServer");
             server.start();
@@ -61,13 +67,27 @@ public class TestServer {
         return server;
     }
 
-    private static SocketConsoleApplicationShell getShell() throws IOException {
+    private static SocketConsoleApplicationShell getShell() throws UnknownHostException {
         if (SHELL == null) {
-            SHELL = new SocketConsoleApplicationShell(3300, "close",
+            input = new PluggableConsoleInput();
-                    ConsoleTestApplication.EXIT, Charset.forName("UTF-8"));
+            input.setPrompt("> \n");
+            output = new PluggableConsoleOutput();
+            manager = new DConnexionManager<>();
+            SHELL = new SocketConsoleApplicationShell(3300,
+                    InetAddress.getByName("127.0.0.1"));
             final ConsoleApplication app = ConsoleTestApplication
-                    .create(SHELL.getOutput(), SHELL.getInput());
+                    .create(output, input, manager);
+            SHELL.setInterface(new SocketConsoleInterface(input, output));
+            SHELL.setConnexionManager(manager);
             SHELL.setApplication(app);
+            final Thread th = new Thread(new Runnable() {
+
+                @Override
+                public void run() {
+                    app.start();
+                }
+            });
+            th.start();
         }
         return SHELL;
     }
@@ -76,33 +96,10 @@ public class TestServer {
      * @throws IOException if the server starting failed */
     public static void main(final String... args) throws IOException {
         try {
-            startServer(false).join();
+            getServer().join();
         } catch (final InterruptedException e) {
             e.printStackTrace();
         }
     }
 
-    public static Thread startServer(final boolean autoClose) throws IOException {
-        if (SHELL == null) {
-            SHELL = new SocketConsoleApplicationShell(3300, autoClose,
-                    ConsoleTestApplication.EXIT, Charset.forName("UTF-8"));
-            final ConsoleApplication app = ConsoleTestApplication
-                    .create(SHELL.getOutput(), SHELL.getInput());
-            SHELL.setApplication(app);
-            server = null;
-        }
-        return getServer();
-    }
-
-    public static Thread startServer(final String closeConnection) throws IOException {
-        if (SHELL == null) {
-            SHELL = new SocketConsoleApplicationShell(3300, closeConnection,
-                    ConsoleTestApplication.EXIT, Charset.forName("UTF-8"));
-            final ConsoleApplication app = ConsoleTestApplication
-                    .create(SHELL.getOutput(), SHELL.getInput());
-            SHELL.setApplication(app);
-            server = null;
-        }
-        return getServer();
-    }
 }

gclc-swt/pom.xml

@@ -1,4 +1,35 @@
 
+<!-- GCLC swt, provide a swt window for console applications                                   -->
+<!-- Copyright (C) 2015-2017 E. Bigeon                      -->
+<!-- mailto:emmanuel@bigeon.fr                                                           -->
+<!--                                                                           -->
+<!-- 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.            -->
+
+
 <!-- Copyright E. Bigeon (2015)                             -->
 <!--                                                                           -->
 <!-- emmanuel@bigeon.fr                                                                  -->
@@ -35,7 +66,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-swt</artifactId>
-  <version>1.1.4-SNAPSHOT</version>
+  <version>1.1.5-SNAPSHOT</version>
   <packaging>jar</packaging>
   <url>http://www.bigeon.fr/emmanuel</url>
   <properties>
@@ -51,7 +82,7 @@
     <dependency>
       <groupId>fr.bigeon</groupId>
       <artifactId>gclc</artifactId>
-      <version>2.0.0</version>
+      <version>2.0.4-SNAPSHOT</version>
     </dependency>
     <dependency>
       <groupId>fr.bigeon</groupId>

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,
@@ -46,12 +43,15 @@ package fr.bigeon.gclc.swt;
  *
  * @author Emmanuel Bigeon */
 public interface ConsoleDelayIO {
-    /** Actually send the input as the prompt next input. */
+    /** Get the input text.
-    void validateInput();
+     * @return the non validated input */
+    String getInput();
 
-    /** @param input the input to set */
+    /** Set the input text.
+     * 
+     * @param input the input to set */
     void setInput(String input);
 
-    /** @return the non validated input */
+    /** Actually send the input as the prompt next input. */
-    String getInput();
+    void validateInput();
 }

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,
@@ -45,40 +42,46 @@ import org.eclipse.swt.events.KeyEvent;
 import fr.bigeon.collections.ArrayRibbon;
 import fr.bigeon.collections.Ribbon;
 
-/** A key listener to validate commands and manage the history of commands
+/** A key listener to validate commands and manage the history of commands.
  *
  * @author Emmanuel Bigeon */
 public final class HistoryTextKeyListener extends KeyAdapter {
 
-    /** The size of commands history */
+    /** The size of commands history. */
     private static final int DEFAULT_HISTORY_SIZE = 10;
-    /** The empty string constant */
+    /** The empty string constant. */
     private static final String EMPTY = ""; //$NON-NLS-1$
-    /** The history ribbon */
+    /** The history ribbon. */
     private final Ribbon<String> commands;
-    /** The current index in history search */
+    /** The current index in history search. */
     private int currentIndex = 0;
-    /** The console to notify of command validation */
+    /** The console to notify of command validation. */
     private final ConsoleDelayIO console;
 
-    /** @param console the console delayed */
+    /** Create the key listener that cycle the history.
-    public HistoryTextKeyListener(ConsoleDelayIO console) {
+     *
+     * @param console the console delayed */
+    public HistoryTextKeyListener(final ConsoleDelayIO console) {
         super();
         this.console = console;
-        this.commands = new ArrayRibbon<>(DEFAULT_HISTORY_SIZE);
+        commands = new ArrayRibbon<>(DEFAULT_HISTORY_SIZE);
     }
 
+    /* (non-Javadoc)
+     * @see org.eclipse.swt.events.KeyAdapter#keyPressed(org.eclipse.swt.events.
+     * KeyEvent) */
     @Override
-    public void keyPressed(KeyEvent e) {
+    public void keyPressed(final KeyEvent e) {
-
         pressedKeyCode(e.keyCode);
     }
 
-    /** @param keyCode the pressed key code */
+    /** Indicate a pressed key combination.
-    public void pressedKeyCode(int keyCode) {
+     *
+     * @param keyCode the pressed key code */
+    public void pressedKeyCode(final int keyCode) {
         // Enter validates the command if prompting
         if (keyCode == '\r') {
-            String input = console.getInput();
+            final String input = console.getInput();
             if (!input.isEmpty()) {
                 commands.add(input);
             }
@@ -90,7 +93,7 @@ public final class HistoryTextKeyListener extends KeyAdapter {
         if (keyCode == SWT.ARROW_UP &&
             currentIndex < commands.size() - 1) {
             currentIndex++;
-            String cmd = commands.get(commands.size() - currentIndex - 1);
+            final String cmd = commands.get(commands.size() - currentIndex - 1);
             console.setInput(cmd);
         }
 
@@ -100,7 +103,7 @@ public final class HistoryTextKeyListener extends KeyAdapter {
                 currentIndex--;
                 console.setInput(EMPTY);
             } else if (currentIndex > 0) {
-                String cmd = commands
+                final String cmd = commands
                         .get(commands.size() - (--currentIndex) - 1);
                 console.setInput(cmd);
             }

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,
@@ -53,37 +50,37 @@ import org.eclipse.swt.widgets.Text;
 import fr.bigeon.gclc.ConsoleApplication;
 import fr.bigeon.gclc.manager.ConsoleInput;
 import fr.bigeon.gclc.manager.ConsoleOutput;
+import fr.bigeon.gclc.tools.ConstantString;
+import fr.bigeon.gclc.tools.StringProvider;
 
-/** A SWT component to connect to gclc {@link ConsoleApplication}
+/** A SWT component to connect to gclc {@link ConsoleApplication}.
  * <p>
  *
  * @author Emmanuel Bigeon */
-public class SWTConsole extends Composite
+public final class SWTConsole extends Composite
         implements ConsoleDelayIO, ConsoleInput, ConsoleOutput {
-    /**
+    /** The number of columns of the layout. */
-     *
-     */
     private static final int LAYOUT_NB_COLUMNS = 2;
-    /** The cmd prefix in the output console */
+    /** The cmd prefix in the output console. */
     private static final String CMD_PREFIX = "[CMD] "; //$NON-NLS-1$
-    /** The class logger */
+    /** The class logger. */
     private static final Logger LOGGER = Logger
             .getLogger(SWTConsole.class.getName());
-    /** The empty string constant */
+    /** The empty string constant. */
     private static final String EMPTY = ""; //$NON-NLS-1$
-    /** The console output text field */
+    /** The console output text field. */
     private final Text consoleOutput;
-    /** The console input text field */
+    /** The console input text field. */
     private final Text consoleInput;
-    /** The prompt label */
+    /** The prompt label. */
     private final Label lblPromptlabel;
-    /** The prompt text */
+    /** The prompt text. */
-    private String prompt = ">"; //$NON-NLS-1$
+    private StringProvider prompt = new ConstantString("> "); //$NON-NLS-1$
-    /** The command entered by the user */
+    /** The command entered by the user. */
     private String command = null;
-    /** If the prompt should be active */
+    /** If the prompt should be active. */
     private boolean prompting = false;
-    /** The object for thread synchronization with the prompt */
+    /** The object for thread synchronization with the prompt. */
     private final Object promptLock = new Object();
 
     /** Create the composite.
@@ -102,7 +99,7 @@ public class SWTConsole extends Composite
         consoleOutput.setRedraw(true);
 
         lblPromptlabel = new Label(this, SWT.NONE);
-        lblPromptlabel.setText(prompt);
+        lblPromptlabel.setText(prompt.apply());
 
         consoleInput = new Text(this, SWT.BORDER);
         consoleInput.setLayoutData(
@@ -121,7 +118,7 @@ public class SWTConsole extends Composite
     @Override
     public void close() {
         synchronized (promptLock) {
-            promptLock.notify();
+            promptLock.notifyAll();
         }
         if (consoleInput.isDisposed()) {
             return;
@@ -140,7 +137,7 @@ public class SWTConsole extends Composite
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.ConsoleManager#getPrompt() */
     @Override
-    public String getPrompt() {
+    public StringProvider getPrompt() {
         return prompt;
     }
 
@@ -149,7 +146,7 @@ public class SWTConsole extends Composite
     @Override
     public void interruptPrompt() {
         synchronized (promptLock) {
-            promptLock.notify();
+            promptLock.notifyAll();
         }
     }
 
@@ -221,6 +218,7 @@ public class SWTConsole extends Composite
                     public void run() {
                         if (!consoleInput.isDisposed()) {
                             consoleInput.setEnabled(true);
+                            lblPromptlabel.setText(prompt.apply());
                             consoleInput.setFocus();
                         }
                     }
@@ -232,6 +230,7 @@ public class SWTConsole extends Composite
                 LOGGER.log(Level.WARNING,
                         "Error in synchronization of prompting", e); //$NON-NLS-1$
                 command = null;
+                Thread.currentThread().interrupt();
             }
         }
         if (isDisposed()) {
@@ -281,13 +280,14 @@ public class SWTConsole extends Composite
                 LOGGER.log(Level.WARNING,
                         "Error in synchronization of prompting", e); //$NON-NLS-1$
                 command = null;
+                Thread.currentThread().interrupt();
             } finally {
                 Display.getDefault().syncExec(new Runnable() {
                     @SuppressWarnings("synthetic-access")
                     @Override
                     public void run() {
                         if (!consoleOutput.isDisposed()) {
-                            lblPromptlabel.setText(prompt);
+                            lblPromptlabel.setText(prompt.apply());
                             // relayout
                             SWTConsole.this.layout();
                         }
@@ -326,14 +326,14 @@ public class SWTConsole extends Composite
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.ConsoleManager#setPrompt(java.lang.String) */
     @Override
-    public void setPrompt(final String prompt) {
+    public void setPrompt(final StringProvider prompt) {
         this.prompt = prompt;
         Display.getDefault().syncExec(new Runnable() {
             @SuppressWarnings("synthetic-access")
             @Override
             public void run() {
                 if (!consoleOutput.isDisposed()) {
-                    lblPromptlabel.setText(prompt);
+                    lblPromptlabel.setText(prompt.apply());
                     // relayout
                     SWTConsole.this.layout();
                 }
@@ -341,6 +341,11 @@ public class SWTConsole extends Composite
         });
     }
     
+    @Override
+    public void setPrompt(String prompt) {
+    	setPrompt(new ConstantString(prompt));
+    }
+
     /** @param string the text */
     public void setText(final String string) {
         consoleInput.setText(string);

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,
@@ -47,7 +44,7 @@ import org.eclipse.swt.widgets.Shell;
  * <p>
  *
  * @author Emmanuel Bigeon */
-public class SWTConsoleShell extends Shell {
+public final class SWTConsoleShell extends Shell {
 
     /** The console component */
     private SWTConsole console;

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,
@@ -58,7 +55,7 @@ import fr.bigeon.gclc.tools.AOutputForwardRunnable;
  * <p>
  *
  * @author Emmanuel Bigeon */
-public class SWTConsoleView extends Composite implements ConsoleDelayIO {
+public final class SWTConsoleView extends Composite implements ConsoleDelayIO {
     /** The local implementation of the forwarding runnable
      *
      * @author Emmanuel Bigeon */
@@ -95,8 +92,7 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
     private final Text consoleOutput;
     /** The console input text field */
     private final Text consoleInput;
-    /** The actual manager */
+    /** The input. */
-    private PipedConsoleOutput manager;
     private PipedConsoleInput input;
     /** The forwarding runnable */
     private ToSWTConsoleForwardRunnable forward;
@@ -160,10 +156,12 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
         consoleInput.setSelection(input.length());
     }
 
-    /** @param manager the manager to set */
+    /** Set the input and output.
+     * 
+     * @param manager the output to set
+     * @param input the input */
     public void setManager(final PipedConsoleOutput manager,
                            final PipedConsoleInput input) {
-        this.manager = manager;
         this.input = input;
         if (forward != null) {
             forward.setRunning(false);

gclc-swt/src/main/java/fr/bigeon/gclc/swt/package-info.java

@@ -0,0 +1,39 @@
+/*
+ * GCLC swt, provide a swt window for console applications
+ * Copyright (C) 2015-2017 E. Bigeon
+ * mailto:emmanuel@bigeon.fr
+ *
+ * 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.package-info.java
+ * Created on: Nov 18, 2017
+ */
+/** SWT components for a frontend of GCLC applications.
+ *
+ * @author Emmanuel Bigeon */
+package fr.bigeon.gclc.swt;

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,

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

@@ -1,10 +1,7 @@
 /*
- * Copyright E. Bigeon (2015)
+ * GCLC swt, provide a swt window for console applications
- *
+ * Copyright (C) 2015-2017 E. Bigeon
- * emmanuel@bigeon.fr
+ * mailto: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,
@@ -72,13 +69,13 @@ public class SWTConsoleViewTest {
         final Shell shell = new Shell(DISPLAY);
         final SWTConsoleView swtConsole = new SWTConsoleView(shell, SWT.NONE);
         try (PipedConsoleOutput manager = new PipedConsoleOutput();
-             PipedConsoleInput input = new PipedConsoleInput()) {
+             PipedConsoleInput input = new PipedConsoleInput(System.out)) {
             swtConsole.setManager(manager, input);
         } catch (final IOException e2) {
             assertNull(e2);
         }
         try (PipedConsoleOutput manager = new PipedConsoleOutput();
-             PipedConsoleInput input = new PipedConsoleInput()) {
+             PipedConsoleInput input = new PipedConsoleInput(System.out)) {
             swtConsole.setManager(manager, input);
             final ConsoleApplication appl = new ConsoleApplication(manager,
                     input,

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>2.0.1</version>
+	<version>2.0.4</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-2.0.1</tag>
+	<tag>gclc-2.0.4</tag>
   </scm>
 </project>

gclc/src/main/java/fr/bigeon/gclc/command/SubedCommand.java

@@ -153,6 +153,8 @@ public final class SubedCommand extends CommandProvider implements ICommand {
             final ICommand c = get(args[0]);
             if (c != null) {
                 c.help(manager, Arrays.copyOfRange(args, 1, args.length));
+            } else {
+              manager.println("No command "+Arrays.toString(args));
             }
         } else {
             // Generic

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

@@ -41,6 +41,8 @@ package fr.bigeon.gclc.manager;
 import java.io.IOException;
 import java.io.InterruptedIOException;
 
+import fr.bigeon.gclc.tools.StringProvider;
+
 /** A console application input.
  *
  * @author Emmanuel Bigeon */
@@ -55,7 +57,7 @@ public interface ConsoleInput extends AutoCloseable {
     /** Get the prompt string.
      *
      * @return the prompt prefix */
-    String getPrompt();
+    StringProvider getPrompt();
 
     /** Indicate to the input that is should interrompt the prompting, if
      * possible.
@@ -111,4 +113,6 @@ public interface ConsoleInput extends AutoCloseable {
      *
      * @param prompt the prompt */
     void setPrompt(String prompt);
+    
+    void setPrompt(StringProvider string);
 }

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

@@ -38,6 +38,9 @@
  */
 package fr.bigeon.gclc.manager;
 
+import fr.bigeon.gclc.tools.ConstantString;
+import fr.bigeon.gclc.tools.StringProvider;
+
 /** A console input that return empty to all prompting.
  *
  * @author Emmanuel Bigeon */
@@ -59,8 +62,8 @@ public final class EmptyInput implements ConsoleInput {
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.manager.ConsoleInput#getPrompt() */
     @Override
-    public String getPrompt() {
+    public StringProvider getPrompt() {
-        return ""; //$NON-NLS-1$
+        return new ConstantString(""); //$NON-NLS-1$
     }
 
     /* (non-Javadoc)
@@ -114,4 +117,8 @@ public final class EmptyInput implements ConsoleInput {
         //
     }
 
+    @Override
+    public void setPrompt(StringProvider string) {
+    	//
+    }
 }

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

@@ -44,6 +44,8 @@ import java.io.PipedOutputStream;
 import java.io.PrintStream;
 import java.nio.charset.StandardCharsets;
 
+import fr.bigeon.gclc.tools.StringProvider;
+
 /** This console input allows to enter commands and retrieve the output as an
  * input.
  * <p>
@@ -87,7 +89,7 @@ public final class PipedConsoleInput
     }
 
     @Override
-    public String getPrompt() {
+    public StringProvider getPrompt() {
         return innerManager.getPrompt();
     }
 
@@ -142,6 +144,11 @@ public final class PipedConsoleInput
         innerManager.setPrompt(prompt);
     }
     
+    @Override
+    public void setPrompt(StringProvider string) {
+    	innerManager.setPrompt(string);
+    }
+
     /** Type a message in the input.
      *
      * @param content the content to type to the application

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

@@ -45,6 +45,9 @@ import java.io.InputStreamReader;
 import java.io.PrintStream;
 import java.nio.charset.Charset;
 
+import fr.bigeon.gclc.tools.ConstantString;
+import fr.bigeon.gclc.tools.StringProvider;
+
 /** A console using the input stream and print stream.
  * <p>
  * The default constructor will use the system standart input and output.
@@ -53,10 +56,10 @@ import java.nio.charset.Charset;
 public final class StreamConsoleInput implements ConsoleInput {
 
     /** The default prompt. */
-    public static final String DEFAULT_PROMPT = "> "; //$NON-NLS-1$
+    public static final StringProvider DEFAULT_PROMPT = new ConstantString("> "); //$NON-NLS-1$
 
     /** The command prompt. It can be changed. */
-    private String prompt = DEFAULT_PROMPT;
+    private StringProvider prompt = DEFAULT_PROMPT;
 
     /** The print stream. */
     private final PrintStream out;
@@ -110,13 +113,12 @@ public final class StreamConsoleInput implements ConsoleInput {
         closed = true;
         reading.setRunning(false);
         promptThread.interrupt();
-        in.close();
     }
 
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.manager.ConsoleInput#getPrompt() */
     @Override
-    public String getPrompt() {
+    public StringProvider getPrompt() {
         return prompt;
     }
 
@@ -139,14 +141,14 @@ public final class StreamConsoleInput implements ConsoleInput {
      * @see fr.bigeon.gclc.ConsoleManager#prompt() */
     @Override
     public String prompt() throws IOException {
-        return prompt(prompt);
+        return prompt(prompt.apply());
     }
 
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.manager.ConsoleManager#prompt(long) */
     @Override
     public String prompt(final long timeout) throws IOException {
-        return prompt(prompt, timeout);
+        return prompt(prompt.apply(), timeout);
     }
 
     /* (non-Javadoc)
@@ -178,7 +180,11 @@ public final class StreamConsoleInput implements ConsoleInput {
      * @see fr.bigeon.gclc.manager.ConsoleInput#setPrompt(java.lang.String) */
     @Override
     public void setPrompt(final String prompt) {
-        this.prompt = prompt;
+        this.prompt = new ConstantString(prompt);
     }
 
+    @Override
+    public void setPrompt(StringProvider string) {
+    	this.prompt = string;
+    }
 }

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

@@ -0,0 +1,50 @@
+/*
+ * 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.
+ */
+package fr.bigeon.gclc.tools;
+
+public class ConstantString implements StringProvider {
+	private String string;
+	
+	
+	
+	@Override
+	public String apply() {
+		return string;
+	}
+
+
+	public ConstantString(String string) {
+		this.string = string;
+	}

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

@@ -0,0 +1,49 @@
+/*
+ * 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.
+ */
+package fr.bigeon.gclc.tools;
+
+/**
+ * A string providing object.
+ * <p>
+ * Implementations of this interface will provide a string, this internal state
+ * of the object may be so that successive calls to the apply method return
+ * different results.
+ * 
+ * @author Emmanuel
+ *
+ */
+public interface StringProvider {
+	String apply();
+}

gclc/src/test/java/fr/bigeon/gclc/manager/SystemConsoleManagerTest.java

@@ -141,7 +141,7 @@ public class SystemConsoleManagerTest {
 
             final String prt = "++";
             manager.setPrompt(prt);
-            assertEquals(prt, manager.getPrompt());
+            assertEquals(prt, manager.getPrompt().apply());
         }
     }