Skip to content

Commit e860b0b

Browse files
committed
fix(db): revert timeout of sending data to zmq
1 parent 5ec01d4 commit e860b0b

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

framework/src/main/java/org/tron/common/logsfilter/nativequeue/NativeMessageQueue.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@ public class NativeMessageQueue {
1111

1212
private static final int DEFAULT_BIND_PORT = 5555;
1313
private static final int DEFAULT_QUEUE_LENGTH = 1000;
14-
private static final int ZMQ_SEND_TIME_OUT = 1_000;
1514
private static NativeMessageQueue instance;
1615
private ZContext context = null;
1716
private ZMQ.Socket publisher = null;
@@ -34,7 +33,7 @@ public boolean start(int bindPort, int sendQueueLength) {
3433
if (Objects.isNull(publisher)) {
3534
return false;
3635
}
37-
publisher.setSendTimeOut(ZMQ_SEND_TIME_OUT);
36+
3837
if (bindPort == 0 || bindPort < 0) {
3938
bindPort = DEFAULT_BIND_PORT;
4039
}

0 commit comments

Comments
 (0)