anchor.diff:      end.
   
   
  +prepare_filling(undefined) ->
  +    undefined;
   prepare_filling(Pattern) ->
       case re:run(Pattern, "{[^}]+}", [global]) of
           {match, [Match]} ->
  
positive.code:     handle_ping(State);
  handle_info({publish, Topic, Payload}, State) ->
      handle_consume(Topic, Payload, State);
  handle_info({'EXIT', C, {shutdown, {connack_error, 'CONNACK_PROTO_VER'}}}, State=#state{cargs=CArgs, ver=4}) ->
      % downgrade to MQTT 3.1
      {ok, C} = emqttc:start_link([{proto_ver, 3} | CArgs]),
      {noreply, State#state{ver=3, mqttc=C}};
  handle_info({'EXIT', C, {shutdown, Error}}, State=#state{mqttc=C, ping_timer=Timer}) ->
      maybe_cancel_timer(Timer),
      {stop, {shutdown, Error}, State};
  
negative.code:             end
          end, Pattern, Values).
  
  prepare_matching(undefined) ->
      undefined;
  prepare_matching(Pattern) ->
      EPattern = binary:replace(Pattern, <<".">>, <<"\\">>, [global, {insert_replaced, 1}]),
      case re:run(EPattern, "{[^}]+}", [global]) of
  