@Override
    public void deleteByUserId(String recipientUserId) {
        int n = getActiveEntityManager()
             .createQuery("DELETE FROM NotificationEntity n WHERE n.recipient = :recipientId")
             .setParameter("recipientId", recipientUserId)
             .executeUpdate();
        LOGGER.debug("Deleted all Notifications for recipient {0}, this resulted in {1} "
             + "records being removed.", recipientUserId, n);
    }
Storage for simple notifications system

@author Marc Savy {@literal <marc@blackparrotlabs.io>}
manager/api/jpa/src/main/java/io/apiman/manager/api/jpa/NotificationRepositoryImpl.java