Skip to content

Commit dcc204f

Browse files
committed
use AutoCloseable instead of Closeable in KafkaSenderImpl, MongodbSenderImpl
1 parent 3530ed2 commit dcc204f

2 files changed

Lines changed: 2 additions & 4 deletions

File tree

plugins/kafkaplugin/src/main/java/org/tron/eventplugin/KafkaSenderImpl.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package org.tron.eventplugin;
22

33
import com.alibaba.fastjson.JSONObject;
4-
import java.io.Closeable;
54
import java.text.SimpleDateFormat;
65
import java.util.Date;
76
import java.util.HashMap;
@@ -20,7 +19,7 @@
2019
import org.apache.kafka.clients.producer.RecordMetadata;
2120

2221
@Slf4j(topic = "event")
23-
public class KafkaSenderImpl implements Closeable {
22+
public class KafkaSenderImpl implements AutoCloseable {
2423

2524
private static KafkaSenderImpl instance = null;
2625

plugins/mongodbplugin/src/main/java/org/tron/eventplugin/MongodbSenderImpl.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import com.alibaba.fastjson.JSON;
44
import com.alibaba.fastjson.JSONObject;
5-
import java.io.Closeable;
65
import java.io.InputStream;
76
import java.util.HashMap;
87
import java.util.Map;
@@ -21,7 +20,7 @@
2120
import org.tron.mongodb.MongoTemplate;
2221

2322
@Slf4j(topic = "event")
24-
public class MongodbSenderImpl implements Closeable {
23+
public class MongodbSenderImpl implements AutoCloseable {
2524

2625
private static MongodbSenderImpl instance = null;
2726
@Getter

0 commit comments

Comments
 (0)