| | |
| | | Thread t = new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | try { |
| | | String line = reader.readLine(); |
| | | // The reader is owned by this thread, which closes it once the stream is drained. |
| | | try (BufferedReader in = reader) { |
| | | String line = in.readLine(); |
| | | while (line != null) { |
| | | if (application != null) { |
| | | LocalizableMessageBuilder buf = new LocalizableMessageBuilder(); |
| | |
| | | isFirstLine = false; |
| | | } |
| | | logger.info(LocalizableMessage.raw("server: " + line)); |
| | | line = reader.readLine(); |
| | | line = in.readLine(); |
| | | } |
| | | } catch (Throwable t) { |
| | | if (application != null) { |
| | |
| | | @Override |
| | | public void run() |
| | | { |
| | | try |
| | | // The reader is owned by this thread, which closes it once the stream is drained. |
| | | try (BufferedReader in = reader) |
| | | { |
| | | String line = reader.readLine(); |
| | | String line = in.readLine(); |
| | | while (line != null) |
| | | { |
| | | if (application != null) { |
| | |
| | | isFinished = true; |
| | | startedIdFound = true; |
| | | } |
| | | line = reader.readLine(); |
| | | line = in.readLine(); |
| | | } |
| | | } catch (Throwable t) |
| | | { |