lib/messaging/adapters/postgres/consumer.rb in messaging-4.0.3.pre vs lib/messaging/adapters/postgres/consumer.rb in messaging-4.0.4.pre

@@ -64,10 +64,10 @@
           Messaging.logger.debug "[#{name}] No new messages. Sleeping"
           sleep 5
         end
 
         def unprocessed_messages_count
-          fetch_messages.count
+          fetch_messages.limit(nil).count
         end
 
         def fetch_messages
           SerializedMessage.in_category(categories)
                            .with_transaction_id_lower_than_any_currently_running_transaction