From 893301db6aa47d3f84528c55ab9eb068f1a0616f Mon Sep 17 00:00:00 2001
From: "ayodele.akingbule" <aakingbule@gmail.com>
Date: Tue, 15 Dec 2020 12:45:47 +0100
Subject: [PATCH] fix(emqx_stomp_protocol): fix Dialyzer warnings

---
 apps/emqx_stomp/src/emqx_stomp_protocol.erl | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/apps/emqx_stomp/src/emqx_stomp_protocol.erl b/apps/emqx_stomp/src/emqx_stomp_protocol.erl
index fd8334ff5..ecefa1dc3 100644
--- a/apps/emqx_stomp/src/emqx_stomp_protocol.erl
+++ b/apps/emqx_stomp/src/emqx_stomp_protocol.erl
@@ -396,20 +396,20 @@ receipt_id(Headers) ->
 
 handle_recv_send_frame(#stomp_frame{command = <<"SEND">>, headers = Headers, body = Body}, State) ->
     Topic = header(<<"destination">>, Headers),
-    maybe_send_receipt(receipt_id(Headers), State),
-    emqx_broker:publish(
+    _ = maybe_send_receipt(receipt_id(Headers), State),
+    _ = emqx_broker:publish(
         make_mqtt_message(Topic, Headers, iolist_to_binary(Body))
     ),
     State.
 
 handle_recv_ack_frame(#stomp_frame{command = <<"ACK">>, headers = Headers}, State) ->
     Id = header(<<"id">>, Headers),
-    maybe_send_receipt(receipt_id(Headers), State),
+    _ = maybe_send_receipt(receipt_id(Headers), State),
     ack(Id, State).
 
 handle_recv_nack_frame(#stomp_frame{command = <<"NACK">>, headers = Headers}, State) ->
     Id = header(<<"id">>, Headers),
-     maybe_send_receipt(receipt_id(Headers), State),
+     _ = maybe_send_receipt(receipt_id(Headers), State),
      nack(Id, State).
 
 ensure_clean_trans_timer(State = #pstate{transaction = Trans}) ->
@@ -468,4 +468,4 @@ interval(incoming_timer, #pstate{heart_beats = HrtBt}) ->
 interval(outgoing_timer, #pstate{heart_beats = HrtBt}) ->
     emqx_stomp_heartbeat:interval(outgoing, HrtBt);
 interval(clean_trans_timer, _) ->
-    ?TRANS_TIMEOUT.
\ No newline at end of file
+    ?TRANS_TIMEOUT.