def create(self):
        if self.process_method == 'queue':
            return self._queue()

        if self.process_method == 'direct':
            return self._direct()
Start RPC server with a given number of workers.
dataset/ETHPy150Open kevinrenskers/django-generic-notifications/notifications/backend/__init__.py/BaseNotificationBackend.create--crossover with--dataset/ETHPy150Open openstack/neutron/neutron/tests/functional/test_server.py/TestRPCServer._serve_rpc