def start_rpc_listeners(self):
self._setup_rpc()<EOL>if not self.endpoints:<EOL><INDENT>return []<EOL><DEDENT>self.conn = n_rpc.create_connection()<EOL>self.conn.create_consumer(self.topic, self.endpoints,<EOL>fanout=False)<EOL>return self.conn.consume_in_threads()<EOL>
Configure all listeners here