(hit.getId()) + "\"}}\n"); L93: writer.write(hit.getSourceAsString()); L94: writer.write("\n"); L95: } catch (final IOException e) { L96: throw new IORuntimeException(e); L97: } L98: return true; L99: }); L100: writer.flush(); L101: } L102: }); L103:...

{ L244: throw new DictionaryException("Failed to write: " + oldItem + " -> " + item, e); L245: } L246: } L247: L248: public void write(final String line) { L249: try { L250: writer.write(line); L251: writer.write(Constants.LINE_SEPARATOR); L252: } catch (final IOException e) { L253: throw new DictionaryException("Failed to write: " + line, e); L254: } L255: } L256: L257: ...

{ L244: throw new DictionaryException("Failed to write: " + oldItem + " -> " + item, e); L245: } L246: } L247: L248: public void write(final String line) { L249: try { L250: writer.write(line); L251: writer.write(Constants.LINE_SEPARATOR); L252: } catch (final IOException e) { L253: throw new DictionaryException("Failed to write: " + line, e); L254: } L255: } L256: L257: ...

StringBuilder appendException(final StringBuilder buf, final Exception exception) { L63: try (ByteArrayOutputStream baos = new ByteArrayOutputStream(); L64: PrintWriter writer = new PrintWriter(baos, false, Constants.CHARSET_UTF_8)) { L65: exception.printStackTrace(writer); L66: writer.flush(); L67: append(buf, "exception", () -> StringEscapeUtils.escapeJson(new String(baos.toByteArray(), Constants.CHARSET_UTF_8))); L68: } catch (final IOException...

{ L246: throw new DictionaryException("Failed to write: " + oldItem + " -> " + item, e); L247: } L248: } L249: L250: public void write(final String line) { L251: try { L252: writer.write(line); L253: writer.write(Constants.LINE_SEPARATOR); L254: } catch (final IOException e) { L255: throw new DictionaryException("Failed to write: " + line, e); L256: } L257: } L258: L259: ...

throws IOException { L65: try (final CurlResponse curlResponse = dictionaryManager.getContentResponse(this); L66: final InputStream inputStream = new BufferedInputStream(curlResponse.getContentAsStream())) { L67: out.write(inputStream); L68: } L69: } L70: L71: public abstract String getType(); L72: L73: public abstract PagingList<T> selectList(int offset, int size); L74: L75: public abstract OptionalEntity<T> get(long id); L76: L77: public abstract...

== null) { L156: throw new JobNotFoundException("Job for " + sessionId + " is not found."); L157: } L158: try { L159: final OutputStream out = jobProcess.getProcess().getOutputStream(); L160: IOUtils.write(command + "\n", out, Constants.CHARSET_UTF_8); L161: out.flush(); L162: } catch (final IOException e) { L163: throw new JobProcessingException(e); L164: } L165: } L166:}...