Repository: camel Updated Branches: refs/heads/camel-2.16.x 253d412b5 -> 899800202 refs/heads/camel-2.17.x 8fd74e423 -> 06f307a0c
socket write should be thread safe Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/06f307a0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/06f307a0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/06f307a0 Branch: refs/heads/camel-2.17.x Commit: 06f307a0c315444663603c80756b01fa4642bc40 Parents: 8fd74e4 Author: Preben Asmussen <preben.asmus...@gmail.com> Authored: Fri Aug 19 19:41:19 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sat Aug 20 10:57:39 2016 +0200 ---------------------------------------------------------------------- .../apache/camel/component/splunk/support/SplunkDataWriter.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/06f307a0/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/support/SplunkDataWriter.java ---------------------------------------------------------------------- diff --git a/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/support/SplunkDataWriter.java b/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/support/SplunkDataWriter.java index ee1a349..5650460 100644 --- a/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/support/SplunkDataWriter.java +++ b/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/support/SplunkDataWriter.java @@ -21,6 +21,7 @@ import java.io.OutputStream; import java.io.OutputStreamWriter; import java.io.Writer; import java.net.Socket; +import java.nio.charset.StandardCharsets; import com.splunk.Args; import com.splunk.Service; @@ -53,10 +54,10 @@ public abstract class SplunkDataWriter implements DataWriter { doWrite(event + SplunkEvent.LINEBREAK); } - protected void doWrite(String event) throws IOException { + protected synchronized void doWrite(String event) throws IOException { LOG.debug("writing event to splunk:" + event); OutputStream ostream = socket.getOutputStream(); - Writer writer = new OutputStreamWriter(ostream, "UTF-8"); + Writer writer = new OutputStreamWriter(ostream, StandardCharsets.UTF_8); writer.write(event); writer.flush(); }
