Merge pull request #9040 from rabbitmq/fix-mqtt-reader-crash
Fix crash in MQTT reader
This commit is contained in:
		
						commit
						79e3c10b59
					
				| 
						 | 
					@ -249,7 +249,7 @@ handle_info({{'DOWN', _QName}, _MRef, process, _Pid, _Reason} = Evt,
 | 
				
			||||||
        {ok, PState} ->
 | 
					        {ok, PState} ->
 | 
				
			||||||
            maybe_process_deferred_recv(control_throttle(pstate(State, PState)));
 | 
					            maybe_process_deferred_recv(control_throttle(pstate(State, PState)));
 | 
				
			||||||
        {error, Reason} ->
 | 
					        {error, Reason} ->
 | 
				
			||||||
            {stop, {shutdown, Reason, State}}
 | 
					            {stop, {shutdown, Reason}, State}
 | 
				
			||||||
    end;
 | 
					    end;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
handle_info({'DOWN', _MRef, process, QPid, _Reason}, State) ->
 | 
					handle_info({'DOWN', _MRef, process, QPid, _Reason}, State) ->
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue