ensure request_id is incremented

diff --git a/lib/client/session.ex b/lib/client/session.ex
index 0753a619f9cd599d0be9ec7653784875d85f1ff9..ec1b7c80b1efc11833241add06a7b043fe5cdd97 100644 (file)
--- a/lib/client/session.ex
+++ b/lib/client/session.ex
@@ -425,10 +425,10 @@ defmodule Wampex.Client.Session do
 
   defp remove_nil_values(message), do: Enum.reject(message, &is_nil/1)
 
-  defp maybe_inject_request_id(r_id, [@yield | _] = message), do: {r_id, message}
-  defp maybe_inject_request_id(r_id, [@hello | _] = message), do: {r_id, message}
-  defp maybe_inject_request_id(r_id, [@abort | _] = message), do: {r_id, message}
-  defp maybe_inject_request_id(r_id, [@error | _] = message), do: {r_id, message}
+  defp maybe_inject_request_id(r_id, [@yield | _] = message), do: {get_request_id(r_id), message}
+  defp maybe_inject_request_id(r_id, [@hello | _] = message), do: {get_request_id(r_id), message}
+  defp maybe_inject_request_id(r_id, [@abort | _] = message), do: {get_request_id(r_id), message}
+  defp maybe_inject_request_id(r_id, [@error | _] = message), do: {get_request_id(r_id), message}
 
   defp maybe_inject_request_id(r_id, message) do
     request_id = get_request_id(r_id)