Commit c0ef72a0 authored by Geoff Simmons's avatar Geoff Simmons

ActiveMQ MQ impl: add an assert to check the worker number in worker shutdown

parent bd7c79e4
......@@ -201,6 +201,7 @@ MQ_WorkerShutdown(void **priv)
err = AMQ_GetNum((AMQ_Worker *) *priv, &wrk_num);
if (err != NULL)
return err;
assert(wrk_num >= 0 && wrk_num < nwrk);
if (connections[wrk_num] != NULL) {
err = AMQ_ConnectionShutdown(connections[wrk_num]);
if (err != NULL)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment