public void reportFailure ( String importerName , String procName , boolean decrementPending ) { StatsInfo statsInfo = getStatsInfo ( importerName , procName ) ; if ( decrementPending ) { statsInfo . m_pendingCount . decrementAndGet ( ) ; } statsInfo . m_failureCount . incrementAndGet ( ) ; }
Use this when the insert fails even before the request is queued by the InternalConnectionHandler