Increased max size of message for base_transfer to prevent superflous…

… splitting up of put and get transfers
cedadev · Nov 21, 2024 · 9d360e8 · 9d360e8
1 parent 9b59192
commit 9d360e8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/nlds_processors/transfer/base_transfer.py b/nlds_processors/transfer/base_transfer.py
@@ -37,6 +37,7 @@ class BaseTransferConsumer(StattingConsumer, ABC):
         _REQUIRE_SECURE: True,
         _PRINT_TRACEBACKS: False,
         _FILELIST_MAX_LENGTH: 1000,
+        StattingConsumer._MESSAGE_MAX_SIZE: 16 * 1000 * 1000
     }
 
     def __init__(self, queue=DEFAULT_QUEUE_NAME):
@@ -46,7 +47,7 @@ def __init__(self, queue=DEFAULT_QUEUE_NAME):
         self.require_secure_fl = self.load_config_value(self._REQUIRE_SECURE)
         self.print_tracebacks_fl = self.load_config_value(self._PRINT_TRACEBACKS)
         self.filelist_max_len = self.load_config_value(self._FILELIST_MAX_LENGTH)
-
+        self.message_max_size = self.load_config_value(self._MESSAGE_MAX_SIZE)
         self.reset()
 
     def _callback_common(self, cm, method, properties, body, connection):