anchor.diff:      %% Setup ping interval
       gen_server:call(?SERVER, { setup_initial_ping, RemoteAddress, RemotePort, FromPid }),
       ok.
  +
  +process_data(_FromPid, RemoteIP, RemotePort, ProtocolMod, Data, CompSpec) ->
  +    ?debug("dlink_tcp:receive_data(): RemoteAddr: {~p, ~p}", [ RemoteIP, RemotePort ]),
  +    ?debug("dlink_tcp:receive_data(): ~p:receive_message(~p)", [ ProtocolMod, Data ]),
  +    Proto = list_to_existing_atom(ProtocolMod),
  +    Proto:receive_message(CompSpec, {RemoteIP, RemotePort},
  +			  base64:decode_to_string(Data)).
   
   process_announce(Msg, FromPid, IP, Port, TID, _Vsn, CompSpec) ->
       [ Avail,
  
positive.code:             false
      end.
  
  send_authorize(Pid, SetupChannel, CompSpec) ->
      {ok,[{address, Address }]} = bt_drv:local_info([address]),
      bt_connection:send(Pid, 
  		       term_to_json(
  			 {struct, 		     
  			  [ { ?DLINK_ARG_TRANSACTION_ID, 1 },
  			    { ?DLINK_ARG_CMD, ?DLINK_CMD_AUTHORIZE },
  			    { ?DLINK_ARG_ADDRESS, bt_address_to_string(Address) },
  			    { ?DLINK_ARG_PORT,  SetupChannel },
                              { ?DLINK_ARG_VERSION, ?DLINK_BT_VER },
  			    { ?DLINK_ARG_CERTIFICATES, {array, get_certificates(CompSpec)} },
  			    { ?DLINK_ARG_SIGNATURE, get_authorize_jwt(CompSpec) } ]})).
  
  connection_authorized(FromPid, {RemoteAddress, RemotePort} = Conn, CompSpec) ->
      case connection_manager:find_connection_by_pid(FromPid) of
  
negative.code: status_string(available  ) -> ?DLINK_ARG_AVAILABLE;
  status_string(unavailable) -> ?DLINK_ARG_UNAVAILABLE.
  
  process_authorize(FromPid, PeerIP, PeerPort, TransactionID, RemoteAddress,
  		  RemotePort, ProtoVersion, Signature, Certificates, CompSpec) ->
      ?info("dlink_tcp:authorize(): Peer Address:   ~p:~p", [PeerIP, PeerPort ]),
      ?info("dlink_tcp:authorize(): Remote Address: ~p~p", [ RemoteAddress, RemotePort ]),
      ?info("dlink_tcp:authorize(): Protocol Ver:   ~p", [ ProtoVersion ]),
      ?debug("dlink_tcp:authorize(): TransactionID:  ~p", [ TransactionID ]),
      ?debug("dlink_tcp:authorize(): Signature:      ~p", [ Signature ]),
  
      { LocalAddress, LocalPort } = rvi_common:node_address_tuple(),
  