* FIX [bridge] fix destroy received client message unexpected.
@@ -236,7 +236,7 @@ server_cb(void *arg)
if (work->proto == PROTO_MQTT_BRIDGE) {
uint8_t type;
type = nng_msg_get_type(msg);
- if (work->flag != CMD_PUBLISH) {
+ if (type != CMD_PUBLISH) {
// only accept publish msg from upstream
work->state = RECV;
nng_msg_free(msg);
