This commit is contained in:
wangjian 2023-03-26 23:07:49 +08:00
parent 8424f6ddfe
commit 96da3ae563
2 changed files with 13 additions and 1 deletions

View File

@ -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()

View File

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