anchor.diff:              end,
   
               UnsubscribeFun =
  -            fun(Topic) when is_list(Topic) ->
  +            fun([W|_] = Topic) when is_binary(W) ->
                       wait_til_ready(),
                       CallingPid = self(),
                       User = {plugin, Mod, CallingPid},
  
positive.code:                    and is_atom(DefaultRegView) ->
              MountPoint = "",
              ClientId = fun(T) ->
                                 base64:encode_to_string(
                                   integer_to_binary(
                                     erlang:phash2(T)
                                    )
                                  )
                         end,
              CallingPid = self(),
              SubscriberId = {MountPoint, ClientId(CallingPid)},
  
negative.code:             end,
  
              PublishFun =
              fun([W|_] = Topic, Payload) when is_binary(W) and is_binary(Payload) ->
                      wait_til_ready(),
                      Msg = #vmq_msg{routing_key=Topic,
                                     mountpoint=MountPoint,
  