Replace lambda method _

Instead of the lambda method _ the method should be imported
from oslo.messaging.openstack.common.gettextutils.

Change-Id: I373337cc1227b0d7b7bf93603b53a64de83721a9
This commit is contained in:
Christian Berendt 2014-08-04 14:23:32 +02:00
parent ee23b54178
commit 7fdeddaa3b
7 changed files with 6 additions and 21 deletions

View File

@ -34,9 +34,6 @@ from oslo.config import cfg
from oslo.messaging._drivers import common as rpc_common
from oslo.messaging._drivers import pool
# FIXME(markmc): remove this
_ = lambda s: s
amqp_opts = [
cfg.BoolOpt('amqp_durable_queues',
default=False,

View File

@ -24,12 +24,10 @@ import six
from oslo import messaging
from oslo.messaging import _utils as utils
from oslo.messaging.openstack.common.gettextutils import _
from oslo.messaging.openstack.common import importutils
from oslo.messaging.openstack.common import jsonutils
# FIXME(markmc): remove this
_ = lambda s: s
LOG = logging.getLogger(__name__)
_EXCEPTIONS_MODULE = 'exceptions' if six.PY2 else 'builtins'

View File

@ -26,13 +26,11 @@ from oslo.messaging._drivers import amqp as rpc_amqp
from oslo.messaging._drivers import amqpdriver
from oslo.messaging._drivers import common as rpc_common
from oslo.messaging import exceptions
from oslo.messaging.openstack.common.gettextutils import _
from oslo.messaging.openstack.common import importutils
from oslo.messaging.openstack.common import jsonutils
from oslo.messaging.openstack.common import network_utils
# FIXME(markmc): remove this
_ = lambda s: s
qpid_codec = importutils.try_import("qpid.codec010")
qpid_messaging = importutils.try_import("qpid.messaging")
qpid_exceptions = importutils.try_import("qpid.messaging.exceptions")

View File

@ -32,11 +32,9 @@ from oslo.messaging._drivers import amqp as rpc_amqp
from oslo.messaging._drivers import amqpdriver
from oslo.messaging._drivers import common as rpc_common
from oslo.messaging import exceptions
from oslo.messaging.openstack.common.gettextutils import _
from oslo.messaging.openstack.common import network_utils
# FIXME(markmc): remove this
_ = lambda s: s
rabbit_opts = [
cfg.StrOpt('kombu_ssl_version',
default='',

View File

@ -33,6 +33,7 @@ from oslo.messaging._drivers import base
from oslo.messaging._drivers import common as rpc_common
from oslo.messaging._executors import impl_eventlet # FIXME(markmc)
from oslo.messaging.openstack.common import excutils
from oslo.messaging.openstack.common.gettextutils import _
from oslo.messaging.openstack.common import importutils
from oslo.messaging.openstack.common import jsonutils
@ -44,9 +45,6 @@ Timeout = eventlet.timeout.Timeout
LOG = logging.getLogger(__name__)
RPCException = rpc_common.RPCException
# FIXME(markmc): remove this
_ = lambda s: s
zmq_opts = [
cfg.StrOpt('rpc_zmq_bind_address', default='*',
help='ZeroMQ bind address. Should be a wildcard (*), '

View File

@ -22,9 +22,7 @@ import logging
import eventlet
from oslo.config import cfg
# FIXME(markmc): remove this
_ = lambda s: s
from oslo.messaging.openstack.common.gettextutils import _
matchmaker_opts = [
cfg.IntOpt('matchmaker_heartbeat_freq',

View File

@ -22,9 +22,7 @@ import logging
from oslo.config import cfg
from oslo.messaging._drivers import matchmaker as mm
# FIXME(markmc): remove this
_ = lambda s: s
from oslo.messaging.openstack.common.gettextutils import _
matchmaker_opts = [
# Matchmaker ring file