class BoltConnectionReadLimiter implements BoltConnectionQueueMonitor {

    @Override
    public synchronized void enqueued( BoltConnection to, Job job )
    {
        queueSize += 1;
        checkLimitsOnEnqueue( to );
    }

    public  BoltConnectionReadLimiter( LogService logService, int lowWatermark, int highWatermark );

}