Skip to content

Commit 1217589

Browse files
committed
Support lazy connection
1 parent c16b86b commit 1217589

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

src/main/java/org/fluentd/logger/sender/RawSocketSender.java

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -70,17 +70,6 @@ public RawSocketSender(String host, int port, int timeout, int bufferCapacity, R
7070
this.reconnector = reconnector;
7171
name = String.format("%s_%d_%d_%d", host, port, timeout, bufferCapacity);
7272
this.timeout = timeout;
73-
open();
74-
}
75-
76-
private void open() {
77-
try {
78-
connect();
79-
} catch (IOException e) {
80-
LOG.error("Failed to connect fluentd: " + server.toString(), e);
81-
LOG.warn("Connection will be retried");
82-
close();
83-
}
8473
}
8574

8675
private void connect() throws IOException {

0 commit comments

Comments
 (0)