anchor.diff:      {noreply, State}.
   
   handle_info(broadcast, #state{channel=Channel, membership=Membership0}=State) ->
  -    Membership = state_awset:query(Membership0),
  +    Membership = ?SET:query(Membership0),
   
       %% Open direct exchanges and default channels.
       lists:foreach(fun(Node) ->
  
positive.code: 
  %% @private
  handle_message({membership, IncomingMembership}, #state{membership=Membership0}=State) ->
      Membership = state_awset:merge(IncomingMembership, Membership0),
      State#state{membership=Membership};
  handle_message({forward_message, ServerRef, Message}, State) ->
      ServerRef ! Message,
  
negative.code: 
  %% @private
  gen_broadcast_subscription(Channel) ->
      BroadcastName = ?BROADCAST,
  
      Sub = #'basic.consume'{queue = BroadcastName},
      #'basic.consume_ok'{consumer_tag = _Tag} = amqp_channel:call(Channel, Sub),
  