diff options
| author | dukhlov <dukhlov@mirantis.com> | 2016-02-20 11:31:15 -0500 |
|---|---|---|
| committer | Dmitriy Ukhlov <dukhlov@mirantis.com> | 2016-02-23 15:00:58 +0000 |
| commit | 1482687ff7f06b8db49b6f604e7be0db8eafe2df (patch) | |
| tree | 7e05dfba559c08c1416a4ae24464fde3d06a4107 /oslo_messaging/_cmd | |
| parent | 92c4f76c797f121bec11e53e7895909807d9ba1d (diff) | |
| download | oslo-messaging-1482687ff7f06b8db49b6f604e7be0db8eafe2df.tar.gz | |
Move server's logic from executors
Now we have situation when openstack projects like Mistral needs
extra oslo.messaging functionality.
But it is too complicated now to to implement something new and
integrate it with current code because there is a little bit mess.
1) Executor should be responsible for how to run jobs
(but now also has code with server logic)
2) Dispatcher should be responsible for routing message to the
target endpoint for processing (but it also has serialisation, sending replies,
executing some executor's callbacks etc)
3) Server should do all server specific logic, we need to have different
implementation of servers for RPC and notification, not different implementations
of dispatchers
This patch fixes 1-st point
Change-Id: Ib6408f408889bb7b7056722be636a5547b1a780d
Diffstat (limited to 'oslo_messaging/_cmd')
| -rw-r--r-- | oslo_messaging/_cmd/zmq_broker.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/oslo_messaging/_cmd/zmq_broker.py b/oslo_messaging/_cmd/zmq_broker.py index 08f3d0a..82c1580 100644 --- a/oslo_messaging/_cmd/zmq_broker.py +++ b/oslo_messaging/_cmd/zmq_broker.py @@ -20,11 +20,11 @@ from oslo_config import cfg from oslo_messaging._drivers import impl_zmq from oslo_messaging._drivers.zmq_driver.broker import zmq_broker -from oslo_messaging._executors import impl_pooledexecutor +from oslo_messaging import server CONF = cfg.CONF CONF.register_opts(impl_zmq.zmq_opts) -CONF.register_opts(impl_pooledexecutor._pool_opts) +CONF.register_opts(server._pool_opts) CONF.rpc_zmq_native = True |