anchor.diff:                        AccMsg
                 end
         end, Msg, ?SUBSCRIBER_DB,
  -     [{match, {'_', {Topic, '_', '_'}}}]);
  +     [{match, {'_', {Topic, '_'}}}]);
   
   %% vmq_reg_pets reg view delivers this format
   publish_({_Topic, Node, _SubscriberId, 0, undefined}, Msg)
  
positive.code:       fun({Key, _}, _) ->
                plumtree_metadata:delete(?SUBSCRIBER_DB, Key)
        end, ok, ?SUBSCRIBER_DB,
        [{match, {SubscriberId, {Topic, '_', '_'}}}]).
  
  -spec remap_subscriptions(subscriber_id()) -> ok.
  remap_subscriptions(SubscriberId) ->
      Node = node(),
      plumtree_metadata:fold(
        fun({{_, {Topic, QoS, TS}}, N}, _) ->
                case N of
                    Node -> ok;
                    _ ->
                        add_subscriber(Topic, QoS, SubscriberId, TS)
                end
        end, ok, ?SUBSCRIBER_DB,
        [{match, {SubscriberId, '_'}},
  
negative.code: %% vmq_reg_trie reg view delivers this format
  publish_({Topic, Node}, Msg) when Node == node() ->
      plumtree_metadata:fold(
        fun({{SubscriberId, {_, QoS}}, [N|_]}, AccMsg) ->
                case Node of
                    N ->
                        QPids =
  