Предположим, у меня есть следующий комбу Connection
, который я получаю Queue
от:
def setup_queue():
with Connection("amqp://some_host@local_ip_address") as connection:
return connection.SimpleQueue("some_queue")
и затем использую его в другом месте:
qu = setup_queue()
while(True):
if input() == 'm':
qu.put("message")
Теперь, если я нажму«Ctrl + c», когда интерпретатор ожидает ввода, будет ли мое соединение автоматически закрываться / освобождаться (как указано в документации) с помощью этого оператора with
? Если нет, то как мне сделать это автоматически?