Skip to content

Commit 671450c

Browse files
committed
Rename flusher -> senderTask
1 parent ecb42a5 commit 671450c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public void run() {
6060
@SuppressWarnings("unused")
6161
private static final Logger logger = LoggerFactory.getLogger(AsyncRawSocketSender.class);
6262

63-
private final ExecutorService flusher = Executors.newSingleThreadExecutor();
63+
private final ExecutorService senderTask = Executors.newSingleThreadExecutor();
6464

6565
private static final ErrorHandler DEFAULT_ERROR_HANDLER = new ErrorHandler() {};
6666

@@ -90,7 +90,7 @@ public AsyncRawSocketSender(String host, int port, int timeout,
9090
@Override
9191
public synchronized void flush() {
9292
final RawSocketSender sender = this.sender;
93-
flusher.execute(new FlushRunnable(sender));
93+
senderTask.execute(new FlushRunnable(sender));
9494
}
9595

9696
@Override
@@ -106,7 +106,7 @@ public boolean emit(String tag, Map<String, Object> data) {
106106
@Override
107107
public boolean emit(final String tag, final long timestamp, final Map<String, Object> data) {
108108
final RawSocketSender sender = this.sender;
109-
flusher.execute(new EmitRunnable(tag, data, sender, timestamp));
109+
senderTask.execute(new EmitRunnable(tag, data, sender, timestamp));
110110

111111
return sender.isConnected() || reconnector.enableReconnection(System.currentTimeMillis());
112112
}

0 commit comments

Comments
 (0)