We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8862018 commit 69deaaeCopy full SHA for 69deaae
1 file changed
framework/src/main/java/org/tron/common/logsfilter/nativequeue/NativeMessageQueue.java
@@ -11,6 +11,7 @@ public class NativeMessageQueue {
11
12
private static final int DEFAULT_BIND_PORT = 5555;
13
private static final int DEFAULT_QUEUE_LENGTH = 1000;
14
+ private static final int ZMQ_SEND_TIME_OUT = 1_000;
15
private static NativeMessageQueue instance;
16
private ZContext context = null;
17
private ZMQ.Socket publisher = null;
@@ -29,7 +30,7 @@ public static NativeMessageQueue getInstance() {
29
30
public boolean start(int bindPort, int sendQueueLength) {
31
context = new ZContext();
32
publisher = context.createSocket(SocketType.PUB);
- publisher.setSendTimeOut(1000);
33
+ publisher.setSendTimeOut(ZMQ_SEND_TIME_OUT);
34
35
if (Objects.isNull(publisher)) {
36
return false;
0 commit comments