fix emit() behavior to return false if an error occurred; fix testReconnectAfterBufferFull() to flush at the end, rather then emit a new event and then flush

Author: Mike Kobyakov

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

@@ -171,7 +171,7 @@ private synchronized boolean send(byte[] bytes) {
         // send pending data
         flush();
 
-        return true;
+        return reconnector.isErrorHistoryEmpty();
     }
 
     @Override

src/test/java/org/fluentd/logger/sender/TestRawSocketSender.java

@@ -390,7 +390,7 @@ public void run() {
             }
             else {
                 // Flush the sender's buffer after the fluentd starts
-                sender.emit(tag, record);
+                sender.flush();
                 break;
             }
         }
@@ -408,4 +408,21 @@ public void run() {
         assertEquals(0, bufferFull.getCount());
         assertEquals(i, elist.size());
     }
+    
+    @Test
+    public void testError() throws Exception {
+        // in this test we will not start a MockFluentd instance and expect to get a false value for emit()
+
+        // start sender
+        int port = MockFluentd.randomPort();
+        Sender sender = new RawSocketSender("localhost", port);
+        String tag = "tag";
+        Map<String, Object> record = new HashMap<String, Object>();
+        record.put("num", port);
+
+        // send and check that the value is false
+        assertTrue(!sender.emit(tag, record));
+        
+        sender.close();
+    }
 }