protected final void afterConsume(Message message){
  if (message != null) {
    pendingCredit.release();
  }
}

protected final void afterConsume ( Message message ) { if ( message != null ) { pendingCredit . release ( ) ; } }
to be called after a message is consumed so the flow control of the test kicks in .
