anchor.diff:  %%--------------------------------------------------------------------
   code_change(_OldVsn, State, _Extra) ->
       {ok, State}.
  +
  +%%%===================================================================
  +%%% Internal functions
  +%%%===================================================================
  +
  +close_socket(_State = #state{socket = Socket}) ->
  +    lager:info("closing ZMQ(sub handler)."),
  +    ok = erlzmq:close(Socket, ?CLOSE_TIMEOUT).
  +
  
positive.code: 	 handle_info/2, terminate/2, code_change/3]).
  
  -define(ZMQ_END_POINT, "tcp://127.0.0.1:6788").
  
  -record(state, { subs    :: list(),
  		 context :: binary(),
  
negative.code:     {ok, Context} = erlzmq:context(),
      {ok, Socket} = erlzmq:socket(Context, pub),
      ok = erlzmq:bind(Socket, ?ZMQ_END_POINT),
      {ok, #state{subs = Subscribes, socket = Socket, context = Context}}.
  
  %%--------------------------------------------------------------------
  %% @private
  