[BG96] Receiving large MQTT messges get intterupted by small AT response

Hi,

We have connected a BG96 to a MQTT broker.
And we subscribe to 7 different topics.
We publish a message and before we receive the +QMTPUB response, we receive a large message on one of the subscribed topics (+/-11kB).
While receiving this data we get the +QMTPUB message and also a smaller message on the same topic we are already receiving.
They get all mixed together, making it impossible to receive them and parse them.

Here is a part of the log with the data which is received:

13:03:16 - mod_at_parser_Feed - state=47 index=11190 buffer=11190 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11191 buffer=11191 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11192 buffer=11192 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11193 buffer=11193 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11194 buffer=11194 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11195 buffer=11195 data=0xA2 ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11196 buffer=11196 data=0x01 ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11197 buffer=11197 data=0x06 ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11198 buffer=11198 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11199 buffer=11199 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11200 buffer=11200 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11201 buffer=11201 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11202 buffer=11202 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11203 buffer=11203 data=0x66 (f)
13:03:16 - mod_at_parser_Feed - state=47 index=11204 buffer=11204 data=0xA2 ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11205 buffer=11205 data=0x01 ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11206 buffer=11206 data=0x0D ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11207 buffer=11207 data=0x0A ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11208 buffer=11208 data=0x2B (+)
13:03:16 - mod_at_parser_Feed - state=47 index=11209 buffer=11209 data=0x51 (Q)
13:03:16 - mod_at_parser_Feed - state=47 index=11210 buffer=11210 data=0x4D (M)
13:03:16 - mod_at_parser_Feed - state=47 index=11211 buffer=11211 data=0x54 (T)
13:03:16 - mod_at_parser_Feed - state=47 index=11212 buffer=11212 data=0x50 (P)
13:03:16 - mod_at_parser_Feed - state=47 index=11213 buffer=11213 data=0x55 (U)
13:03:16 - mod_at_parser_Feed - state=47 index=11214 buffer=11214 data=0x42 (B)
13:03:16 - mod_at_parser_Feed - state=47 index=11215 buffer=11215 data=0x3A (:)
13:03:16 - mod_at_parser_Feed - state=47 index=11216 buffer=11216 data=0x20 ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11217 buffer=11217 data=0x30 (0)
13:03:16 - mod_at_parser_Feed - state=47 index=11218 buffer=11218 data=0x2C (,)
13:03:16 - mod_at_parser_Feed - state=47 index=11219 buffer=11219 data=0x31 (1)
13:03:16 - mod_at_parser_Feed - state=47 index=11220 buffer=11220 data=0x2C (,)
13:03:16 - mod_at_parser_Feed - state=47 index=11221 buffer=11221 data=0x30 (0)
13:03:16 - mod_at_parser_Feed - state=47 index=11222 buffer=11222 data=0x0D ( )
13:03:16 - mod_at_parser_Feed - state=47 index=11223 buffer=11223 data=0x0A ( )
13:03:18 - mod_at_serial_HasData - result=0 bytes=4095 error=0 "Success"
13:03:18 - mod_at_serial_HasData - result=0 bytes=4095 error=0 "Success"
13:03:18 - mod_at_serial_Read - bytes=2048 error=0 "Success"
13:03:18 - mod_at_SerialRead - bytes=2048
13:03:18 - mod_at_parser_Feed - state=47 index=11224 buffer=11224 data=0x0D ( )
13:03:18 - mod_at_parser_Feed - state=47 index=11225 buffer=11225 data=0x0A ( )
13:03:18 - mod_at_parser_Feed - state=47 index=11226 buffer=11226 data=0x2B (+)
13:03:18 - mod_at_parser_Feed - state=47 index=11227 buffer=11227 data=0x51 (Q)
13:03:18 - mod_at_parser_Feed - state=47 index=11228 buffer=11228 data=0x4D (M)
13:03:18 - mod_at_parser_Feed - state=47 index=11229 buffer=11229 data=0x54 (T)
13:03:18 - mod_at_parser_Feed - state=47 index=11230 buffer=11230 data=0x52 (R)
13:03:18 - mod_at_parser_Feed - state=47 index=11231 buffer=11231 data=0x45 (E)
13:03:18 - mod_at_parser_Feed - state=47 index=11232 buffer=11232 data=0x43 (C)
13:03:18 - mod_at_parser_Feed - state=47 index=11233 buffer=11233 data=0x56 (V)
13:03:18 - mod_at_parser_Feed - state=47 index=11234 buffer=11234 data=0x3A (:)
13:03:18 - mod_at_parser_Feed - state=47 index=11235 buffer=11235 data=0x20 ( )
13:03:18 - mod_at_parser_Feed - state=47 index=11236 buffer=11236 data=0x30 (0)
13:03:18 - mod_at_parser_Feed - state=47 index=11237 buffer=11237 data=0x2C (,)
13:03:18 - mod_at_parser_Feed - state=47 index=11238 buffer=11238 data=0x35 (5)
13:03:18 - mod_at_parser_Feed - state=47 index=11239 buffer=11239 data=0x2C (,)
13:03:18 - mod_at_parser_Feed - state=47 index=11240 buffer=11240 data=0x22 (")
13:03:18 - mod_at_parser_Feed - state=47 index=11241 buffer=11241 data=0x74 (t)
13:03:18 - mod_at_parser_Feed - state=47 index=11242 buffer=11242 data=0x72 (r)
13:03:18 - mod_at_parser_Feed - state=47 index=11243 buffer=11243 data=0x61 (a)
13:03:18 - mod_at_parser_Feed - state=47 index=11244 buffer=11244 data=0x76 (v)
13:03:18 - mod_at_parser_Feed - state=47 index=11245 buffer=11245 data=0x65 (e)
13:03:18 - mod_at_parser_Feed - state=47 index=11246 buffer=11246 data=0x6C (l)
13:03:18 - mod_at_parser_Feed - state=47 index=11247 buffer=11247 data=0x69 (i)
13:03:18 - mod_at_parser_Feed - state=47 index=11248 buffer=11248 data=0x6E (n)
13:03:18 - mod_at_parser_Feed - state=47 index=11249 buffer=11249 data=0x66 (f)
13:03:18 - mod_at_parser_Feed - state=47 index=11250 buffer=11250 data=0x6F (o)
13:03:18 - mod_at_parser_Feed - state=47 index=11251 buffer=11251 data=0x2F (/)
13:03:18 - mod_at_parser_Feed - state=47 index=11252 buffer=11252 data=0x34 (4)
13:03:18 - mod_at_parser_Feed - state=47 index=11253 buffer=11253 data=0x2F (/)
13:03:18 - mod_at_parser_Feed - state=47 index=11254 buffer=11254 data=0x32 (2)
13:03:18 - mod_at_parser_Feed - state=47 index=11255 buffer=11255 data=0x2F (/)
13:03:18 - mod_at_parser_Feed - state=47 index=11256 buffer=11256 data=0x51 (Q)
13:03:18 - mod_at_parser_Feed - state=47 index=11257 buffer=11257 data=0x2D (-)
13:03:18 - mod_at_parser_Feed - state=47 index=11258 buffer=11258 data=0x4C (L)
13:03:18 - mod_at_parser_Feed - state=47 index=11259 buffer=11259 data=0x49 (I)
13:03:18 - mod_at_parser_Feed - state=47 index=11260 buffer=11260 data=0x54 (T)
13:03:18 - mod_at_parser_Feed - state=47 index=11261 buffer=11261 data=0x45 (E)
13:03:18 - mod_at_parser_Feed - state=47 index=11262 buffer=11262 data=0x2F (/)
13:03:18 - mod_at_parser_Feed - state=47 index=11263 buffer=11263 data=0x32 (2)
13:03:18 - mod_at_parser_Feed - state=47 index=11264 buffer=11264 data=0x32 (2)
13:03:18 - mod_at_parser_Feed - state=47 index=11265 buffer=11265 data=0x2D (-)
13:03:18 - mod_at_parser_Feed - state=47 index=11266 buffer=11266 data=0x36 (6)
13:03:18 - mod_at_parser_Feed - state=47 index=11267 buffer=11267 data=0x35 (5)
13:03:18 - mod_at_parser_Feed - state=47 index=11268 buffer=11268 data=0x39 (9)

Is this a known issue? What can we do to solve this?

The current firmware version of the module is: BG96MAR02A08M1G_01.200.01.200

@herbert.pan-Q, Could you help me with this issue? Or could you forward this to someone who can help?

These messages may be reply messages that the MQTT server must reply to after you publish the message; It is suggested that you can 1) turn off reply reply on MQTT server if MQTT allows it; 2) Try to unsubscribe the topic of this reply