Fixed termination to consume last message rather that read it at
the beginning of the next execution of the consumer.