anchor.diff:            end,
   
       TranslatedMsg = try
  -      records_translator:translate(Msg, Message_decoder_name)
  +      records_translator:translate(Msg, DecoderName1)
       catch
         _:message_not_supported -> throw({message_not_supported, MsgId})
       end,
  
positive.code: %%      In case of 'pull' message - InputMessage is decoded with decode_clustermsg_pb/2. <br/>
  %%      In case of 'push' message - InputMessage is decoded with decode_answermsg_pb/2.
  %% @end
  -spec decode_providermsg_pb(MsgBytes :: binary(), DN :: string()) -> Result when
      Result :: {pull | push, FuseId :: binary(), InputMessage :: term()}.
  %% ====================================================================
  decode_providermsg_pb(MsgBytes, DN) ->
      DecodedBytes = try
          communication_protocol_pb:decode_providermsg(MsgBytes)
                     catch
  
negative.code:     Req :: term(),
      State :: #hander_state{}.
  %% ====================================================================
  websocket_handle({binary, Data}, Req, #hander_state{peer_type = PeerType} = State) ->
      try
          Request =
              case PeerType of
                  provider -> decode_providermsg_pb(Data);
                  user     -> decode_clustermsg_pb(Data)
              end,
  
          ?debug("Received request: ~p", [Request]),
  