Commit 2c69073c authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Testing: changed prefetch_count from 1 to 16. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent fa53259b

transfer_service/amqp_server.py

+1 −1
Original line number Diff line number Diff line
@@ -15,7 +15,7 @@ class AMQPServer(threading.Thread): 
        self.connection = pika.BlockingConnection(pika.ConnectionParameters(host = self.host, port = self.port))

        self.channel = self.connection.channel();

        self.channel.queue_declare(queue = self.queue)

        self.channel.basic_qos(prefetch_count = 1)

        self.channel.basic_qos(prefetch_count = 16)

        threading.Thread(target = self.channel.basic_consume(queue = self.queue, on_message_callback = self.on_request))



    def on_request(self, ch, method, props, body):