Tentative implementation of MQ consumption.