Skip to content

Commit

Permalink
Revert "Added redis transport key_prefix from envvars"
Browse files Browse the repository at this point in the history
This reverts commit d440278.
  • Loading branch information
matusvalo authored and auvipy committed Sep 8, 2020
1 parent a042d57 commit 56e88dc
Showing 1 changed file with 4 additions and 9 deletions.
13 changes: 4 additions & 9 deletions kombu/transport/redis.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
"""Redis transport."""

import os
import numbers
import socket

Expand Down Expand Up @@ -56,10 +55,6 @@
Probably the key ({1!r}) has been removed from the Redis database.
"""

KEY_PREFIX = os.environ.get('KOMBU_REDIS_PREFIX', '')
if KEY_PREFIX:
KEY_PREFIX = '{p}:'.format(p=KEY_PREFIX)

# This implementation may seem overly complex, but I assure you there is
# a good reason for doing it this way.
#
Expand Down Expand Up @@ -408,16 +403,16 @@ class Channel(virtual.Channel):
_subclient = None
_closing = False
supports_fanout = True
keyprefix_queue = '{p}_kombu.binding.%s'.format(p=KEY_PREFIX)
keyprefix_queue = '_kombu.binding.%s'
keyprefix_fanout = '/{db}.'
sep = '\x06\x16'
_in_poll = False
_in_listen = False
_fanout_queues = {}
ack_emulation = True
unacked_key = '{p}unacked'.format(p=KEY_PREFIX)
unacked_index_key = '{p}unacked_index'.format(p=KEY_PREFIX)
unacked_mutex_key = '{p}unacked_mutex'.format(p=KEY_PREFIX)
unacked_key = 'unacked'
unacked_index_key = 'unacked_index'
unacked_mutex_key = 'unacked_mutex'
unacked_mutex_expire = 300 # 5 minutes
unacked_restore_limit = None
visibility_timeout = 3600 # 1 hour
Expand Down

0 comments on commit 56e88dc

Please sign in to comment.