added support for destroying message queues on the MessageQueueWorker thread while blocking the caller of the onDestroy method (which will be the cluster thread responsible for rebalancing)