def METHOD_NAME(self, connector_service, wamp_service, _filter):
    self.filter = _filter
    self.emulated = False
    options = {"details_arg": str('details')}
    if None in _filter:
        options["match"] = "wildcard"
    options = SubscribeOptions(**options)
    _filter = WampMQ.messageTopic(_filter)
    self.unreg = yield connector_service.METHOD_NAME(self.wampInvoke, _filter, options=options)
    if self.callback is None:
        yield self.stopConsuming()