Revert "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"

This reverts commit d7ab7b8.

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 reconnector.isErrorHistoryEmpty();
+        return true;
     }
 
     @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.flush();
+                sender.emit(tag, record);
                 break;
             }
         }
@@ -408,21 +408,4 @@ 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();
-    }
 }