Skip to content

Commit 549768e

Browse files
Use erpc instead of rpc
1 parent 7dedb90 commit 549768e

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

lib/ecto_mysql_extras.ex

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -88,13 +88,15 @@ defmodule EctoMySQLExtras do
8888
end
8989

9090
defp query!({repo, node}, query, query_opts) do
91-
case :rpc.call(node, repo, :query!, [query, [], query_opts]) do
92-
{:badrpc, {:EXIT, {:undef, _}}} ->
91+
try do
92+
:erpc.call(node, repo, :query!, [query, [], query_opts])
93+
catch
94+
:error, {:exception, :undef, _} ->
9395
raise "repository is not defined on remote node"
9496

95-
{:badrpc, error} ->
97+
:error, {:erpc, error} ->
9698
raise "cannot send query to remote node #{inspect(node)}. Reason: #{inspect(error)}"
97-
99+
else
98100
result ->
99101
result
100102
end

test/ecto_mysql_extras_test.exs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,7 @@ defmodule EctoMySQLExtrasTest do
259259
node_name = :"[email protected]"
260260

261261
assert_raise RuntimeError,
262-
"cannot send query to remote node #{inspect(node_name)}. Reason: :nodedown",
262+
"cannot send query to remote node #{inspect(node_name)}. Reason: :noconnection",
263263
fn ->
264264
EctoMySQLExtras.query(:plugins, {EctoMySQLExtras.TestRepo, node_name})
265265
end

0 commit comments

Comments
 (0)