Consuming messages conditionally