private void storeWithSubscribers ( final List < LogLineTableEntity > lines ) { synchronized ( subscribers ) { if ( subscribers . isEmpty ( ) ) return ; // No subscribers, ignore call for ( LogSubscriber subscriber : subscribers ) { subscriber . append ( lines ) ; } if ( System . currentTimeMillis ( ) > nextSubscriberPurge ) { purgeIdleSubscribers ( ) ; nextSubscriberPurge = System . currentTimeMillis ( ) + purgeSubscriberInterval . getMilliseconds ( ) ; } } }
Makes the provided log lines available to all log tail subscribers