Skip to content

Commit 5e8f2c2

Browse files
author
Mike Kobyakov
committed
add isConnected() methods to logger and sender; enhance tests with this functionality
1 parent 1065567 commit 5e8f2c2

File tree

4 files changed

+16
-0
lines changed

4 files changed

+16
-0
lines changed

src/main/java/org/fluentd/logger/FluentLogger.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,4 +128,8 @@ public void finalize() {
128128
sender.close();
129129
}
130130
}
131+
132+
public boolean isConnected() {
133+
return sender != null && sender.isConnected();
134+
}
131135
}

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,4 +50,9 @@ public String getName() {
5050
public String toString() {
5151
return this.getClass().getName();
5252
}
53+
54+
@Override
55+
public boolean isConnected() {
56+
return true;
57+
}
5358
}

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -211,4 +211,9 @@ public String getName() {
211211
public String toString() {
212212
return getName();
213213
}
214+
215+
@Override
216+
public boolean isConnected() {
217+
return socket != null && !socket.isClosed() && socket.isConnected() && !socket.isOutputShutdown();
218+
}
214219
}

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,4 +29,6 @@ public interface Sender {
2929
void close();
3030

3131
String getName();
32+
33+
boolean isConnected();
3234
}

0 commit comments

Comments
 (0)