mirror of
https://github.com/fhmq/hmq.git
synced 2026-05-02 14:28:34 +00:00
plugins
This commit is contained in:
@@ -30,7 +30,7 @@ type Config struct {
|
|||||||
|
|
||||||
//Init init kafak client
|
//Init init kafak client
|
||||||
func Init() {
|
func Init() {
|
||||||
content, err := ioutil.ReadFile("../../plugins/kafka/conf.json")
|
content, err := ioutil.ReadFile("./plugins/authhttp/http.json")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal("Read config file error: ", zap.Error(err))
|
log.Fatal("Read config file error: ", zap.Error(err))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -36,7 +36,7 @@ type Config struct {
|
|||||||
|
|
||||||
//Init init kafak client
|
//Init init kafak client
|
||||||
func Init() {
|
func Init() {
|
||||||
content, err := ioutil.ReadFile("../../plugins/kafka/conf.json")
|
content, err := ioutil.ReadFile("./plugins/kafka/conf.json")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal("Read config file error: ", zap.Error(err))
|
log.Fatal("Read config file error: ", zap.Error(err))
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user