Reduce error logging if reconnect is disabled (fluent#16).

rmelick · Apr 21, 2016 · 5aba277 · 5aba277
1 parent 0e21d8b
commit 5aba277
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/org/fluentd/logger/sender/RawSocketSender.java b/src/main/java/org/fluentd/logger/sender/RawSocketSender.java
@@ -152,6 +152,8 @@ private boolean flushBuffer() {
             flush();
             if (pendings.position() == 0) {
                 return true;
+            } else {
+                LOG.error("Cannot send logs to " + server.toString());
             }
         }
 
@@ -162,7 +164,6 @@ private synchronized boolean send(byte[] bytes) {
         // buffering
         if (pendings.position() + bytes.length > pendings.capacity()) {
             if (!flushBuffer()) {
-                LOG.error("Cannot send logs to " + server.toString());
                 return false;
             }
         }