synchronized modifier for org.fluentd.logger.sender.RawSocketSender.close

dmitry.malyuga · dmitry.malyuga · commit 8bde3de1dc53 · 2018-12-04T12:23:25.000+03:00
Signed-off-by: dmitry.malyuga &lt;dmitry.malyuga@reltio.com&gt;
diff --git a/src/main/java/org/fluentd/logger/sender/RawSocketSender.java b/src/main/java/org/fluentd/logger/sender/RawSocketSender.java
@@ -99,7 +99,7 @@ private void reconnect() throws IOException {
     }
 
     @Override
-    public void close() {
+    public synchronized void close() {
         // close output stream
         if (out != null) {
             try {

Original file line number	Diff line number	Diff line change
`@@ -99,7 +99,7 @@ private void reconnect() throws IOException {`
`99`	`99`	`}`
`100`	`100`
`101`	`101`	`@Override`
`102`		`- public void close() {`
	`102`	`+ public synchronized void close() {`
`103`	`103`	`// close output stream`
`104`	`104`	`if (out != null) {`
`105`	`105`	`try {`