add more error parse

xflagstudio · Jun 9, 2017 · 0a89e4b · 0a89e4b
1 parent d239d53
commit 0a89e4b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/redix_cluster/run.ex b/lib/redix_cluster/run.ex
@@ -131,6 +131,10 @@ defmodule RedixCluster.Run do
     RedixCluster.Monitor.refresh_mapping(version)
     {:error, :retry}
   end
+  defp parse_trans_result({:error, %Redix.Error{message: <<"CLUSTERDOWN", _::binary>>}}, {version, _pool_name}, _command, _type, _opts) do
+    RedixCluster.Monitor.refresh_mapping(version)
+    {:error, :retry}
+  end
   defp parse_trans_result(payload, _, _, _, _), do: payload
 
   defp verify_command_key(term1, term2) do