anchor.diff:  -spec execute(block_state()) -> block_state().
   
   execute({Config, Inputs, Outputs, Private}) ->
  -
     % Block is enabled at this point, 
     % Start MQTT client if not already started
     case attrib_utils:get_value(Private, client) of
  
positive.code:               % Return updated block state
                {Config, Inputs, Outputs1, Private1};
  
  
              {ok, message} ->
                % Read received publish message(s) if any, and update subscribed output values
                {Outputs1, Private2} = process_pub_msgs(Config, Outputs, Private1),
  
  
negative.code:               Private1 = Private
            end,
  
            BlockName = config_utils:name(Config),
            case attrib_utils:get_value(Outputs, exec_method) of
              {ok, input_cos} ->
                log_server:debug("Executing: ~p Exec Method: ~p", [BlockName, input_cos]),
                % An input value has changed
                % Read inputs, publish values to corresponding topics
                pub_topics(Config, Inputs, Client),
  