anchor.diff:      Ret = Callback:publish(Transport, Socket, Topic, Content),
   	lager:info("ret= ~p", [Ret]),
   	case Ret of
  -		{error, Err} ->
  +		{error, _Err} ->
   			{stop, normal, disconnect, StateData};
   
   		ok ->
  
positive.code:             false
      end.
  
  garbage_collect(Pid) ->
      ok.
  
  %
  
negative.code:     Ret = Callback:crlfping(Transport, Socket),
      lager:info("send CRLF ping= ~p", [Ret]),
      case Ret of
          {error, _Err} ->
              {stop, normal, disconnect, StateData};
  
          ok ->
              {reply, ok, connected, StateData, 5000}
      end;
  
  connected(_,_, _StateData) ->
      {stop, normal, disconnect, undefined}.
  
  connected({timeout, _, timeout1}, _StateData) ->
  	lager:info("timeout after connection"),
  	{stop, disconnect, []};
  
  