void sampleReceived ( SolverAggregatorInterface aggregator , SampleMessage sample ) { if ( ! this . sampleQueue . offer ( sample ) && this . warnBufferFull ) { log . warn ( "Unable to insert a sample due to a full buffer." ) ; } }
Called when the aggregator sends a sample . Enqueues the sample into the internal buffer .