Added queue declaration and changed exchange from amq.direct to the unnamed direct exchange.