Skip to content

Commit e4f8766

Browse files
authored
Merge pull request #5014 from 317787106/hotfix/revert_zmq_timeout
fix(db): Revert sending timeout of zmq
2 parents 5ec01d4 + e860b0b commit e4f8766

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)