mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Remove verbose debug messages

pull/8/head
Nicolas Jouanin 2015-08-10 22:05:03 +02:00
rodzic b1cb963ece
commit 43de5e4b4c
1 zmienionych plików z 6 dodań i 9 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

15
hbmqtt/broker.py
Wyświetl plik

@ -654,9 +654,9 @@ class Broker:
@asyncio.coroutine @asyncio.coroutine
def broadcast_application_message(self, source_session, topic, data, force_qos=None): def broadcast_application_message(self, source_session, topic, data, force_qos=None):
self.logger.debug("Broadcasting message from %s on topic %s" % #self.logger.debug("Broadcasting message from %s on topic %s" %
(format_client_message(session=source_session), topic) # (format_client_message(session=source_session), topic)
) # )
publish_tasks = [] publish_tasks = []
try: try:
for k_filter in self._subscriptions: for k_filter in self._subscriptions:
@ -688,12 +688,9 @@ class Broker:
asyncio.wait(publish_tasks) asyncio.wait(publish_tasks)
except Exception as e: except Exception as e:
self.logger.warn("Message broadcasting failed: %s", e) self.logger.warn("Message broadcasting failed: %s", e)
self.logger.debug("End Broadcasting message from %s on topic %s" % #self.logger.debug("End Broadcasting message from %s on topic %s" %
(format_client_message(session=source_session), topic) # (format_client_message(session=source_session), topic)
) # )
for client_id in self._sessions:
self.logger.debug("%s Retained messages queue size: %d" %
(client_id, self._sessions[client_id].retained_messages.qsize()))
@asyncio.coroutine @asyncio.coroutine
def publish_session_retained_messages(self, session): def publish_session_retained_messages(self, session):