Skip to content

Commit 20137ae

Browse files
homma-takamasaoza
authored andcommitted
Fix to return false if it exceeds the buffer capacity.
1 parent 3825803 commit 20137ae

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/main/scala/org/fluentd/logger/scala/sender/ScalaRawSocketSender.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,8 +107,7 @@ class ScalaRawSocketSender(h:String, p:Int, to:Int, bufCap:Int)
107107
try {
108108
// serialize tag, timestamp and data
109109
val json = Serialization.write(event)
110-
send(json.getBytes("UTF-8"))
111-
true
110+
return send(json.getBytes("UTF-8"))
112111
} catch {
113112
case e: IOException =>
114113
LOG.severe(s"Cannot serialize event: $event")

0 commit comments

Comments
 (0)