PGQ consumer for Java.