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:     gen_fsm:cancel_timer(Ref),
      {reply, undefined, connected, StateData#session{pingid=undefined}, round(Ka*1.5)};
  
  connected(#mqtt_msg{type='PUBLISH', qos=Qos, payload=P}, _, StateData=#session{deviceid=DeviceID,keepalive=Ka}) ->
      Topic   = proplists:get_value(topic, P),
      Content = proplists:get_value(data, P),
  
  
negative.code:             false
      end.
  
  garbage_collect(_Pid) ->
      ok.
  
  %
  