def all_control_queues_for_declare(config):
 possible_uwsgi_queues = []
 if process_is_uwsgi:
  import uwsgi
  possible_uwsgi_queues = [Queue(('control.%s.%s' % (config.server_name.split('.')[0], wkr['id'])), galaxy_exchange, routing_key='control') for wkr in uwsgi.workers()]
 return (possible_uwsgi_queues + [Queue(('control.%s' % q), galaxy_exchange, routing_key='control') for q in config.server_names])

def all_control_queues_for_declare ( config ) : possible_uwsgi_queues = [ ] if process_is_uwsgi : import uwsgi possible_uwsgi_queues = [ Queue ( ( 'control.%s.%s' % ( config . server_name . split ( '.' ) [ 0 ] , wkr [ 'id' ] ) ) , galaxy_exchange , routing_key = 'control' ) for wkr in uwsgi . workers ( ) ] return ( possible_uwsgi_queues + [ Queue ( ( 'control.%s' % q ) , galaxy_exchange , routing_key = 'control' ) for q in config . server_names ] )
for in-memory routing .