diff --git a/src/emqx_alarm_handler.erl b/src/emqx_alarm_handler.erl index e40c85bb9..ca4f4f9bb 100644 --- a/src/emqx_alarm_handler.erl +++ b/src/emqx_alarm_handler.erl @@ -195,4 +195,4 @@ set_alarm_history(Id, Desc) -> His = #alarm_history{id = Id, desc = Desc, clear_at = os:timestamp()}, - mnesia:dirty_write(?ALARM_HISTORY_TAB, His}). + mnesia:dirty_write(?ALARM_HISTORY_TAB, His). diff --git a/src/emqx_connection.erl b/src/emqx_connection.erl index f58e2fa57..b7478e445 100644 --- a/src/emqx_connection.erl +++ b/src/emqx_connection.erl @@ -234,11 +234,6 @@ connected(cast, {incoming, Packet = ?PACKET(Type)}, State) -> connected(info, Deliver = {deliver, _Topic, _Msg}, State = #state{chan_state = ChanState}) -> Delivers = emqx_misc:drain_deliver([Deliver]), - %% TODO: ... - case BatchLen = length(Delivers) of - 1 -> ok; - N -> io:format("Batch Deliver: ~w~n", [N]) - end, case emqx_channel:handle_out(Delivers, ChanState) of {ok, NChanState} -> keep_state(State#state{chan_state = NChanState});