cmd/server.go

@@ -80,7 +80,6 @@ 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

@@ -15,15 +15,4 @@ functions:
   - name: echo-sf
   - 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
+  - name: task-execute

go.mod

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