fmt

alttch · Nov 15, 2021 · b03e8cd · b03e8cd
1 parent 8781cc1
commit b03e8cd
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/eva/notify.py b/lib/eva/notify.py
@@ -2629,7 +2629,8 @@ def on_connect(self, client, userdata, flags, rc):
         if self.announce_interval and not self.test_only_mode:
             eva.core.spawn_daemon(self.start_announcer)
         if not self.api_callback_lock.acquire(timeout=eva.core.config.timeout):
-            logging.critical('.GenericPubSubNotifier::on_connect locking broken')
+            logging.critical(
+                '.GenericPubSubNotifier::on_connect locking broken')
             eva.core.critical()
             return False
         try:
@@ -3154,7 +3155,8 @@ def send_api_response(self, call_id, data):
     def send_api_request(self, request_id, controller_id, data, callback):
         try:
             if request_id in self.api_callback:
-                logging.error('.GenericPubSubNotifier: duplicate API request ID')
+                logging.error(
+                    '.GenericPubSubNotifier: duplicate API request ID')
                 return False
             if not self.api_callback_lock.acquire(
                     timeout=eva.core.config.timeout):
@@ -4344,7 +4346,7 @@ def load_notifier(notifier_id, ncfg=None, test=True, connect=True):
         fmt = ncfg.get('fmt')
         host = ncfg.get('host')
         port = ncfg.get('port')
-        max_frame_size = ncfg.get('max_frame_size')
+        max_frame_size = ncfg.get('max_frame_size', 65000)
         n = UDPNotifier(notifier_id,
                         interval=interval,
                         buf_ttl=buf_ttl,