Skip to content

Commit 6dfc821

Browse files
committed
Make sender.isConnected to be thread safe
1 parent 2672908 commit 6dfc821

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ public boolean emit(final String tag, final long timestamp, final Map<String, Ob
108108
final RawSocketSender sender = this.sender;
109109
senderTask.execute(new EmitRunnable(tag, data, sender, timestamp));
110110

111-
return sender.isConnected() || reconnector.enableReconnection(System.currentTimeMillis());
111+
return this.isConnected() || reconnector.enableReconnection(System.currentTimeMillis());
112112
}
113113

114114
@Override
@@ -117,7 +117,7 @@ public String getName() {
117117
}
118118

119119
@Override
120-
public boolean isConnected() {
120+
public synchronized boolean isConnected() {
121121
return sender.isConnected();
122122
}
123123

0 commit comments

Comments
 (0)