Fix ZeroMQ port mismatch.

This commit is contained in:
Luke Sneeringer 2014-11-25 10:39:42 -06:00
parent f8cbdd65a5
commit 27933df220

View File

@ -59,7 +59,8 @@ class Socket(object):
@property
def port(self):
return {
'callbacks': settings.CALLBACK_CONSUMER_PORT,
'callbacks': os.environ.get('CALLBACK_CONSUMER_PORT',
settings.CALLBACK_CONSUMER_PORT),
'task_commands': settings.TASK_COMMAND_PORT,
'websocket': settings.SOCKETIO_NOTIFICATION_PORT,
}[self._bucket]