hmq
hmq copied to clipboard
fhmq
High performance mqtt broker
### Issue Separately initialized brokers that use the same topics will share messages between them. The underlying topic and session management is not isolated on construction of new brokers. I...
{"level":"error","timestamp":"2022-07-05T14:20:39.912+0800","logger":"broker","caller":"broker/client.go:179","msg":" read packet error: ","error":"EOF","ClientID":"iotmqtt","stacktrace":"github.com/fhmq/hmq/broker.(*client).readLoop\n\tD:/code/hmq/broker/client.go:179\ngithub.com/fhmq/hmq/broker.(*Broker).handleConnection\n\tD:/code/hmq/broker/broker.go:430"}
I am having trouble using the **clean_session=false** . For example, when a subscriber (**clean_session=false**) subscribes to a topic (**QoS1**), after it goes offline for some reason. Another publisher publishes information...
who has the experience for the hmq's benchmark? comparing with emqx or others brokers....
We are seeing this: ``` WARNING: DATA RACE Write at 0x00c0008ca0b0 by goroutine 271: github.com/fhmq/hmq/broker.(*client).Close() /home/circleci/project/pkg/mod/github.com/fhmq/[email protected]/broker/client.go:611 +0xb2 github.com/fhmq/hmq/broker.ProcessMessage() /home/circleci/project/pkg/mod/github.com/fhmq/[email protected]/broker/client.go:194 +0x411 github.com/fhmq/hmq/broker.(*Broker).SubmitWork.func1() /home/circleci/project/pkg/mod/github.com/fhmq/[email protected]/broker/broker.go:110 +0x44 github.com/fhmq/hmq/pool.startWorker.func1() /home/circleci/project/pkg/mod/github.com/fhmq/[email protected]/pool/fixpool.go:55 +0x31 Previous read at 0x00c0008ca0b0...
 //line930 
Steps to reproduce: 1. Run `hmq` 2. Run `mosquitto_sub -t '#'` 3. Run this Go program: ```go package main import ( "fmt" "log" mqtt "github.com/eclipse/paho.mqtt.golang" ) func publishInvalid() error {...
Can bridgeMq receive the qos configurations? To control a message if acked ? Thanks for your reply!
