fix

cmd/server.go

@@ -80,6 +80,7 @@ func NewStartCmd() *cobra.Command {
 				signal.Notify(c, syscall.SIGINT, syscall.SIGTERM)
 			}(exitChannel)
 			mq, err := hpds_node.NewMq(configFileFlag)
+			must(err)
 			mq.InitOptions(hpds_node.WithAuth("token", cfg.Token))
 			defer mq.Close()
 

config/config.yaml

@@ -16,3 +16,14 @@ functions:
   - name: task-request
   - name: task-response
   - name: task-execute
+logging:
+  path: ./logs
+  prefix: mq-node
+  errorFileSuffix: error.log
+  warnFileSuffix: warn.log
+  infoFileSuffix: info.log
+  debugFileSuffix: debug.log
+  maxSize: 100
+  maxBackups: 3000
+  maxAge: 30
+  development: true

go.mod

@@ -3,8 +3,8 @@ module hpds_mq
 go 1.19
 
 require (
-	git.hpds.cc/Component/network v0.0.0-20221012021659-2433c68452d5
-	git.hpds.cc/pavement/hpds_node v0.0.0-20230307094826-753c4fe9c877
+	git.hpds.cc/Component/network v0.0.0-20230310154952-a750964220b6
+	git.hpds.cc/pavement/hpds_node v0.0.0-20230324004901-e0eab082e6ab
 	github.com/hashicorp/consul/api v1.15.3
 	github.com/spf13/cobra v1.6.0
 	github.com/spf13/viper v1.13.0
@@ -86,4 +86,3 @@ require (
 	gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 )
-