package Ġcom . logstash Ċ Ċ import Ġco . elastic . logstash . api . Configuration Ċ import Ġco . elastic . logstash . api . Event Ċ import Ġcom . logstash . Kotlin Output Plugin . Companion . PREFIX _ CONFIG Ċ import Ġorg . junit . jupiter . api . Test Ċ import Ġorg . logstash . plugins . Configuration Impl Ċ import Ġorg . logstash . plugins . Context Impl Ċ import Ġjava . io . ByteArray OutputStream Ċ import Ġjava . io . Print Stream Ċ import Ġkotlin . test . assertTrue ĊĊ Ċ class ĠKotlin Input Plugin Test Ġ{ ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` test Java Output Example `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġprefix Ġ= Ġ" Prefix -" ĊĠĠĠĠĠĠĠ Ġval Ġconfig Values Ġ= Ġmap Of ( PREFIX _ CONFIG . name () Ġto Ġprefix ) ĊĠĠĠĠĠĠĠ Ġval Ġconfig : ĠConfiguration Ġ= ĠConfiguration Impl ( config Values ) ĊĊĠĠĠĠĠĠĠ Ġval ĠbyteArray OutputStream Ġ= ĠByteArrayOutputStream () ĊĠĠĠĠĠĠĠ Ġval Ġkotlin Output Plugin Ġ= ĠKotlin Output Plugin ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" test - id ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġconfig , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠContext Impl ( null , Ġnull ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠPrint Stream ( byteArray OutputStream ) ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ Ġval Ġevent : ĠEvent Ġ= Ġorg . logstash . Event () ĊĠĠĠĠĠĠĠ Ġval Ġexpected Event Me Message Ġ= Ġ" Input ĠMessage " ĊĠĠĠĠĠĠĠ Ġevent . setField (" message ", Ġexpected Event Me Message ) ĊĊĠĠĠĠĠĠĠ Ġkotlin Output Plugin . output ( listOf ( event )) ĊĊĠĠĠĠĠĠĠ ĠassertTrue Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠbyteArray OutputStream . toString (). contains ( prefix ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ&& ĠbyteArray OutputStream . toString (). contains ( expected Event Me Message ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }