fixed issue with messages being consumed unless next() was called