def create_consumers(dispatcher, prefix, topic_details):
 connection = rpc.create_connection(new=True)
 for (topic, operation) in topic_details:
  topic_name = topics.get_topic_name(prefix, topic, operation)
  connection.create_consumer(topic_name, dispatcher, fanout=True)
 connection.consume_in_thread()
 return connection

def create_consumers ( dispatcher , prefix , topic_details ) : connection = rpc . create_connection ( new = True ) for ( topic , operation ) in topic_details : topic_name = topics . get_topic_name ( prefix , topic , operation ) connection . create_consumer ( topic_name , dispatcher , fanout = True ) connection . consume_in_thread ( ) return connection
create agent rpc consumers .