diff --git a/util/src/main/resources/com/ning/billing/util/notificationq/dao/NotificationSqlDao.sql.stg b/util/src/main/resources/com/ning/billing/util/notificationq/dao/NotificationSqlDao.sql.stg
index 3afc5e3..3b3311e 100644
--- a/util/src/main/resources/com/ning/billing/util/notificationq/dao/NotificationSqlDao.sql.stg
+++ b/util/src/main/resources/com/ning/billing/util/notificationq/dao/NotificationSqlDao.sql.stg
@@ -63,7 +63,7 @@ select
, tenant_record_id
from notifications
where queue_name = :queueName
-and processing_state != 'REMOVED'
+and processing_state = 'AVAILABLE'
and account_record_id = :accountRecordId
and effective_date >= :now
order by effective_date, record_id
