public ResilientSyslogOutputStream(String syslogHost, int port) throws UnknownHostException, SocketException { this.syslogHost = syslogHost; this.port = port; super.os = new SyslogOutputStream(syslogHost, port); this.presumedClean = true; }
private OutputStream createOutputStream() throws IOException { switch (protocol) { case TCP: return new TcpOutputStream(host, port); case UDP: return new SyslogOutputStream(host, port); default: throw new IOException("Unsupported protocol: " + protocol); } }
@Override OutputStream openNewOutputStream() throws IOException { return new SyslogOutputStream(syslogHost, port); }
@Override public SyslogOutputStream createOutputStream() throws SocketException, UnknownHostException { return new SyslogOutputStream(getSyslogHost(), getPort()); }