@Test void buildWithCustomPort() throws IOException { try (Fluency fluency = new FluencyBuilderForFluentd().build(54321)) { assertBuffer(fluency.getBuffer()); assertFlusher(fluency.getFlusher()); assertDefaultFluentdSender( (FluentdSender) fluency.getFlusher().getIngester().getSender(), "127.0.0.1", 54321, TCPSender.class); } }
public Fluency build(String host, int port) { return buildFromIngester( buildRecordFormatter(), buildIngester(createBaseSender(host, port))); }
FluencyBuilderForFluentd extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String host, int port) { return buildFromIngester( buildRecordFormatter(), buildIngester(createBaseSender(host, port))); } }
FluencyBuilderForFluentd extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String host, int port) { return buildFromIngester( buildRecordFormatter(), buildIngester(createBaseSender(host, port))); }  }
FluencyBuilderForFluentd extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String host, int port) { return buildFromIngester( buildRecordFormatter(), buildIngester(createBaseSender(host, port))); }  Integer getSenderMaxRetryCount(); Integer getSenderBaseRetryIntervalMillis(); Integer getSenderMaxRetryIntervalMillis(); void setSenderBaseRetryIntervalMillis(Integer senderBaseRetryIntervalMillis); void setSenderMaxRetryIntervalMillis(Integer senderMaxRetryIntervalMillis); void setSenderMaxRetryCount(Integer senderMaxRetryCount); boolean isAckResponseMode(); void setAckResponseMode(boolean ackResponseMode); boolean isSslEnabled(); void setSslEnabled(boolean sslEnabled); Integer getConnectionTimeoutMilli(); void setConnectionTimeoutMilli(Integer connectionTimeoutMilli); Integer getReadTimeoutMilli(); void setReadTimeoutMilli(Integer readTimeoutMilli); Fluency build(String host, int port); Fluency build(int port); Fluency build(); Fluency build(List<InetSocketAddress> servers); @Override String toString(); }
FluencyBuilderForFluentd extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String host, int port) { return buildFromIngester( buildRecordFormatter(), buildIngester(createBaseSender(host, port))); }  Integer getSenderMaxRetryCount(); Integer getSenderBaseRetryIntervalMillis(); Integer getSenderMaxRetryIntervalMillis(); void setSenderBaseRetryIntervalMillis(Integer senderBaseRetryIntervalMillis); void setSenderMaxRetryIntervalMillis(Integer senderMaxRetryIntervalMillis); void setSenderMaxRetryCount(Integer senderMaxRetryCount); boolean isAckResponseMode(); void setAckResponseMode(boolean ackResponseMode); boolean isSslEnabled(); void setSslEnabled(boolean sslEnabled); Integer getConnectionTimeoutMilli(); void setConnectionTimeoutMilli(Integer connectionTimeoutMilli); Integer getReadTimeoutMilli(); void setReadTimeoutMilli(Integer readTimeoutMilli); Fluency build(String host, int port); Fluency build(int port); Fluency build(); Fluency build(List<InetSocketAddress> servers); @Override String toString();  }