/usr/share/pyshared/fedmsg/commands/hub.py is in python-fedmsg 0.7.1-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 | # This file is part of fedmsg.
# Copyright (C) 2012 Red Hat, Inc.
#
# fedmsg is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# fedmsg is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with fedmsg; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
#
# Authors: Ralph Bean <rbean@redhat.com>
#
import fedmsg
from fedmsg.utils import load_class
from fedmsg.commands import BaseCommand
class HubCommand(BaseCommand):
""" Run the fedmsg hub.
``fedmsg-hub`` is the all-purpose daemon. This should be run on every host
that has services which declare their own consumers. ``fedmsg-hub`` will
listen to every endpoint discovered by :mod:`fedmsg.config` and forward
messages in-process to the locally-declared consumers. It is a thin
wrapper over a moksha-hub.
Other commands like ``fedmsg-irc`` are just specialized, restricted
versions of ``fedmsg-hub``. ``fedmsg-hub`` is the most general/abstract.
``fedmsg-hub`` also houses the functions to run a websocket server.
"""
name = 'fedmsg-hub'
daemonizable = True
extra_args = [
(['--with-consumers'], {
'dest': 'explicit_hub_consumers',
'type': str,
'help': 'A comma-delimited list of conumers to run.',
'default': None,
}),
(['--websocket-server-port'], {
'dest': 'moksha.livesocket.websocket.port',
'type': int,
'help': 'Port on which to host the websocket server.',
'default': None,
}),
]
def run(self):
# Check if the user wants the websocket server to run
if self.config['moksha.livesocket.websocket.port']:
self.config['moksha.livesocket.backend'] = 'websocket'
# If the user wants to override any consumers installed on the system
# and *only* run the ones they want to, they can do that.
consumers = None
if self.config['explicit_hub_consumers']:
locations = self.config['explicit_hub_consumers'].split(',')
locations = [load_class(location) for location in locations]
# Rephrase the fedmsg-config.py config as moksha *.ini format.
# Note that the hub we kick off here cannot send any message. You
# should use fedmsg.publish(...) still for that.
moksha_options = dict(
zmq_subscribe_endpoints=','.join(
','.join(bunch) for bunch in self.config['endpoints'].values()
),
)
self.config.update(moksha_options)
from moksha.hub import main
main(
# Pass in our config dict
options=self.config,
# Only run the specified consumers if any are so specified.
consumers=consumers,
# Tell moksha to quiet its logging.
framework=False,
)
def hub():
command = HubCommand()
command.execute()
|