115 def init_publisher(self): |
115 def init_publisher(self): |
116 config = self.config |
116 config = self.config |
117 # when we have an in-memory repository, clean unused sessions every XX |
117 # when we have an in-memory repository, clean unused sessions every XX |
118 # seconds and properly shutdown the server |
118 # seconds and properly shutdown the server |
119 if config.repo_method == 'inmemory': |
119 if config.repo_method == 'inmemory': |
120 reactor.addSystemEventTrigger('before', 'shutdown', |
|
121 self.shutdown_event) |
|
122 if config.pyro_enabled(): |
120 if config.pyro_enabled(): |
123 # if pyro is enabled, we have to register to the pyro name |
121 # if pyro is enabled, we have to register to the pyro name |
124 # server, create a pyro daemon, and create a task to handle pyro |
122 # server, create a pyro daemon, and create a task to handle pyro |
125 # requests |
123 # requests |
126 self.pyro_daemon = self.appli.repo.pyro_register() |
124 self.pyro_daemon = self.appli.repo.pyro_register() |
127 self.pyro_listen_timeout = 0.02 |
125 self.pyro_listen_timeout = 0.02 |
128 self.appli.repo.looping_task(1, self.pyro_loop_event) |
126 self.appli.repo.looping_task(1, self.pyro_loop_event) |
129 self.appli.repo.start_looping_tasks() |
127 if config.mode != 'test': |
|
128 reactor.addSystemEventTrigger('before', 'shutdown', |
|
129 self.shutdown_event) |
|
130 self.appli.repo.start_looping_tasks() |
130 self.set_url_rewriter() |
131 self.set_url_rewriter() |
131 CW_EVENT_MANAGER.bind('after-registry-reload', self.set_url_rewriter) |
132 CW_EVENT_MANAGER.bind('after-registry-reload', self.set_url_rewriter) |
132 |
133 |
133 def start_service(self): |
134 def start_service(self): |
134 start_task(self.appli.session_handler.clean_sessions_interval, |
135 start_task(self.appli.session_handler.clean_sessions_interval, |