Skip to content

Client couldn't receive response if response is larger than 1M when broker set messageSizeLimit=4194304#56

Open
freedai wants to merge 1 commit intoopendxl:masterfrom
freedai:master
Open

Client couldn't receive response if response is larger than 1M when broker set messageSizeLimit=4194304#56
freedai wants to merge 1 commit intoopendxl:masterfrom
freedai:master

Conversation

@freedai
Copy link

@freedai freedai commented Jan 27, 2021

Debug message with client sending request:

DEBUG:dxlclient.client:MQTT: Sending PUBLISH (d0, q0, r0, m10), 'b'/mcafee/client/{01e2e422-b7eb-4b3d-b8bd-0d7784f3335d}'', ... (4178151 bytes)
DEBUG:dxlclient.client:MQTT: Received PUBLISH (d0, q0, r0, m0), '/mcafee/client/{01e2e422-b7eb-4b3d-b8bd-0d7784f3335d}', ...  (4178405 bytes)
DEBUG:dxlclient.client:Message received for topic /mcafee/client/{01e2e422-b7eb-4b3d-b8bd-0d7784f3335d}
ERROR:dxlclient._thread_pool:Error in worker thread
Traceback (most recent call last):
  File "/usr/local/lib/python3.8/site-packages/dxlclient/_thread_pool.py", line 54, in run
    func(*args, **kargs)
  File "/usr/local/lib/python3.8/site-packages/dxlclient/client.py", line 1158, in _handle_message
    message = Message._from_bytes(payload)
  File "/usr/local/lib/python3.8/site-packages/dxlclient/message.py", line 373, in _from_bytes
    message._unpack_message(unpacker)
  File "/usr/local/lib/python3.8/site-packages/dxlclient/message.py", line 555, in _unpack_message
    super(Response, self)._unpack_message(unpacker)
  File "/usr/local/lib/python3.8/site-packages/dxlclient/message.py", line 229, in _unpack_message
    self._payload = next(unpacker)
  File "/usr/local/lib/python3.8/site-packages/msgpack/fallback.py", line 685, in __next__
    ret = self._unpack(EX_CONSTRUCT)
  File "/usr/local/lib/python3.8/site-packages/msgpack/fallback.py", line 617, in _unpack
    typ, n, obj = self._read_header(execute)
  File "/usr/local/lib/python3.8/site-packages/msgpack/fallback.py", line 582, in _read_header
    raise ValueError("%s exceeds max_str_len(%s)", n, self._max_str_len)
ValueError: ('%s exceeds max_str_len(%s)', 4177932, 1048576)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant