anchor.diff:  %% 2) we need to bind the queues using the new routing key
   %%    and unbind them from the old one.
   notify(_VHost, <<"stream-connection-params">>, Name, Term) ->
  -    io:format("notify Term: ~p~n", [Name, Term]),
  +    io:format("notify Name: ~p Term: ~p~n", [Name, Term]),
       ok.
   
   %% A stream definition is gone. We can't remove queues so
  
positive.code: validate(_VHost, <<"stream-connection-params">>, Name, Term) ->
      rabbit_parameter_validation:proplist(
        Name, [{<<"uri">>, fun validate_uri/2, mandatory},
               {<<"routing-key">>, fun rabbit_parameter_validation:number/2}], Term);
  
  validate(_VHost, _Component, Name, _Term) ->
      {error, "name not recognised: ~p", [Name]}.
  
negative.code:     ok.
  
  validate_shards_per_node(Name, Term) when is_number(Term) ->
      case Term >= 0 of
          true  ->
              ok;
          false ->
  