Skip to content

Commit

Permalink
* FIX [mqtt/proto] Update the level of logs.
Browse files Browse the repository at this point in the history
Signed-off-by: wanghaemq <[email protected]>
  • Loading branch information
wanghaEMQ committed Jul 2, 2024
1 parent b98ffb7 commit 0cd9c0a
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/mqtt/protocol/mqtt/mqtt_client.c
Original file line number Diff line number Diff line change
Expand Up @@ -648,7 +648,7 @@ mqtt_timer_cb(void *arg)
if (aio != NULL && (msg = nni_aio_get_msg(aio)) != NULL) {
nni_msg_clone(msg);
s->lastpid = pid;
log_info("NO.%d Batch sending id%d msg%p", s->batchcnt-1, pid, msg);
log_debug("NO.%d Batch sending id%d msg%p", s->batchcnt-1, pid, msg);
ptype = nni_mqtt_msg_get_packet_type(msg);
if (ptype == NNG_MQTT_PUBLISH)
nni_mqtt_msg_set_publish_dup(msg, true);
Expand Down Expand Up @@ -701,7 +701,7 @@ mqtt_timer_cb(void *arg)
nni_msg_clone(msg);
s->lastpid = pid;
s->batchcnt ++;
log_info("Batch sending started id%d msg%p", pid, msg);
log_debug("Batch sending started id%d msg%p", pid, msg);
ptype = nni_mqtt_msg_get_packet_type(msg);
if (ptype == NNG_MQTT_PUBLISH)
nni_mqtt_msg_set_publish_dup(msg, true);
Expand Down

0 comments on commit 0cd9c0a

Please sign in to comment.