File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
sdk/logs/src/main/java/io/opentelemetry/sdk/logs Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -40,17 +40,15 @@ static LogRecordProcessor composite(LogRecordProcessor... processors) {
4040 */
4141 static LogRecordProcessor composite (Iterable <LogRecordProcessor > processors ) {
4242 List <LogRecordProcessor > processorList = new ArrayList <>();
43- BatchLogRecordProcessor batchProcessor = null ;
43+ List < BatchLogRecordProcessor > batchProcessors = new ArrayList <>() ;
4444 for (LogRecordProcessor processor : processors ) {
4545 if (!BatchLogRecordProcessor .class .equals (processor .getClass ())) {
4646 processorList .add (processor );
4747 } else {
48- batchProcessor = ( BatchLogRecordProcessor ) processor ;
48+ batchProcessors . add (( BatchLogRecordProcessor ) processor ) ;
4949 }
5050 }
51- if (batchProcessor != null ) {
52- processorList .add (batchProcessor );
53- }
51+ processorList .addAll (batchProcessors );
5452
5553 if (processorList .isEmpty ()) {
5654 return NoopLogRecordProcessor .getInstance ();
You can’t perform that action at this time.
0 commit comments