Skip to content

Commit 8862018

Browse files
committed
feat(db): add sending timeout of zmq
1 parent ebf49a9 commit 8862018

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ public static NativeMessageQueue getInstance() {
2929
public boolean start(int bindPort, int sendQueueLength) {
3030
context = new ZContext();
3131
publisher = context.createSocket(SocketType.PUB);
32+
publisher.setSendTimeOut(1000);
3233

3334
if (Objects.isNull(publisher)) {
3435
return false;

0 commit comments

Comments
 (0)