Changeset 548 for trunk/daemon/orbited/start.py

Timestamp:

10/10/08 08:26:54 (3 months ago)

Author:

heyadayo

Message:

Auto detect Orbited.settings.hostname and Orbited.settings.port; Required morbid for install; Allow Orbited to use morbid to act as an embedded stomp broker.

Files:

• trunk/daemon/orbited/start.py (modified) (4 diffs)

trunk/daemon/orbited/start.py

@@ -25 +25 @@
             reactor.listenWith(port_class, factory=factory_class(), resource=root, childName=child_path)
             logger.info('%s protocol active' % config_key)
-
+    
 def _setup_static(root, config):
     from twisted.web import static
@@ -46 +46 @@
     global logger; logger = logging.get_logger('orbited.start')
 
+
     # NB: we need to install the reactor before using twisted.
     reactor_name = config.map['[global]'].get('reactor')
@@ -61 +62 @@
     static_files = static.File(os.path.join(os.path.dirname(__file__), 'static'))
     root.putChild('static', static_files)
+    #static_files.putChild('orbited.swf', static.File(os.path.join(os.path.dirname(__file__), 'flash', 'orbited.swf')))
     site = server.Site(root)
 
@@ -70 +72 @@
 def start_listening(site, config, logger):
     from twisted.internet import reactor
+    # allow stomp:// URIs to be parsed by urlparse 
+    urlparse.uses_netloc.append('stomp')
+
     for addr in config['[listen]']:
         url = urlparse.urlparse(addr)
         hostname = url.hostname or ''
-        if url.scheme == 'http':
+        if url.scheme == 'stomp':
+            logger.info('Listening stomp@%s' % url.port)
+            from morbid import StompFactory
+            reactor.listenTCP(url.port, StompFactory(), interface=hostname)     
+        elif url.scheme == 'http':
             logger.info('Listening http@%s' % url.port)
             reactor.listenTCP(url.port, site, interface=hostname)