Fix monitor to add monitor message header

shun159 · Apr 23, 2016 · a553e37 · a553e37
1 parent 2f386a5
commit a553e37
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/eovsdb_client.erl b/src/eovsdb_client.erl
@@ -189,7 +189,7 @@ handle_info({'DOWN', MonRef, process, _MonPid, _Reason},
     eovsdb_protocol:monitor_cancel(ConnPid),
     erlang:demonitor(MonRef),
     {noreply, State};
-handle_info({monitor_update, Update},
+handle_info({ovsdb_monitor, _} = Update,
             State = #?STATE{monitor_pid = MPid}) ->
     erlang:send(MPid, Update),
     {noreply, State};

diff --git a/src/eovsdb_protocol.erl b/src/eovsdb_protocol.erl
@@ -241,7 +241,7 @@ handle_message(#{ <<"method">> := <<"update">> } = Data,
                State = #?STATE{ monitor_pid = MPid }) ->
     #{ <<"params">> := Params } = Data,
     [_, Update] = Params,
-    erlang:send(MPid, {monitor_update, Update}),
+    erlang:send(MPid, {ovsdb_monitor, Update}),
     State;
 handle_message(Data, State = #?STATE{pending_message = PM0}) ->
     #{ <<"id">> := Id,