fix(db): reorder setSendTimeOut function

317787106 · 317787106 · commit 14c1c80bc088 · 2023-02-20T17:41:27.000+08:00
diff --git a/framework/src/main/java/org/tron/common/logsfilter/nativequeue/NativeMessageQueue.java b/framework/src/main/java/org/tron/common/logsfilter/nativequeue/NativeMessageQueue.java
@@ -30,12 +30,11 @@ public static NativeMessageQueue getInstance() {
   public boolean start(int bindPort, int sendQueueLength) {
     context = new ZContext();
     publisher = context.createSocket(SocketType.PUB);
-    publisher.setSendTimeOut(ZMQ_SEND_TIME_OUT);
 
     if (Objects.isNull(publisher)) {
       return false;
     }
-
+    publisher.setSendTimeOut(ZMQ_SEND_TIME_OUT);
     if (bindPort == 0 || bindPort < 0) {
       bindPort = DEFAULT_BIND_PORT;
     }

Original file line number	Diff line number	Diff line change
`@@ -30,12 +30,11 @@ public static NativeMessageQueue getInstance() {`
`30`	`30`	`public boolean start(int bindPort, int sendQueueLength) {`
`31`	`31`	`context = new ZContext();`
`32`	`32`	`publisher = context.createSocket(SocketType.PUB);`
`33`		`- publisher.setSendTimeOut(ZMQ_SEND_TIME_OUT);`
`34`	`33`
`35`	`34`	`if (Objects.isNull(publisher)) {`
`36`	`35`	`return false;`
`37`	`36`	`}`
`38`		`-`
	`37`	`+ publisher.setSendTimeOut(ZMQ_SEND_TIME_OUT);`
`39`	`38`	`if (bindPort == 0 \|\| bindPort < 0) {`
`40`	`39`	`bindPort = DEFAULT_BIND_PORT;`
`41`	`40`	`}`