File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -107,6 +107,9 @@ def open_connection(self):
107107 handler = logging .StreamHandler ()
108108 handler .setFormatter (self .formatter )
109109 rabbitmq_logger = logging .getLogger ('pika' )
110+ rabbitmq_logger_propagate = rabbitmq_logger .propagate
111+ rabbitmq_logger_level = rabbitmq_logger .level
112+
110113 rabbitmq_logger .addHandler (handler )
111114 rabbitmq_logger .propagate = False
112115 rabbitmq_logger .setLevel (logging .WARNING )
@@ -123,6 +126,8 @@ def open_connection(self):
123126 self .exchange_declared = True
124127
125128 # Manually remove logger to avoid shutdown message.
129+ rabbitmq_logger .propagate = rabbitmq_logger_propagate
130+ rabbitmq_logger .setlevel (rabbitmq_logger_level )
126131 rabbitmq_logger .removeHandler (handler )
127132
128133 def close_connection (self ):
You can’t perform that action at this time.
0 commit comments