private boolean hasMessagesPending ( ) { for ( Map . Entry < MessageQueue , ConcurrentSkipListSet < MessageExt > > entry : messageQueueTreeSetMap . entrySet ( ) ) { if ( ! entry . getValue ( ) . isEmpty ( ) ) { return true ; } } return false ; }
Check if there are locally pending messages to consume .