mirror of https://github.com/celery/kombu.git
Merge branch 'master' of github.com:celery/kombu
This commit is contained in:
commit
84a92f8d38
|
@ -895,7 +895,7 @@ class ChannelPool(Resource):
|
||||||
def maybe_channel(channel):
|
def maybe_channel(channel):
|
||||||
"""Return the default channel if argument is a connection instance,
|
"""Return the default channel if argument is a connection instance,
|
||||||
otherwise just return the channel given."""
|
otherwise just return the channel given."""
|
||||||
if isinstance(channel, Connection):
|
if is_connection(channel):
|
||||||
return channel.default_channel
|
return channel.default_channel
|
||||||
return channel
|
return channel
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue