package Ġio . mic ronaut . mqtt . docs . custom . annotation Ċ Ċ // Ġtag :: imports [] Ċ import Ġio . mic ronaut . mqtt . annotation . Mqtt Subscriber Ċ import Ġio . mic ronaut . mqtt . annotation . Topic Ċ import Ġjava . nio . charset . StandardCharsets Ċ Ċ import Ġjava . util . Collections Ċ import Ġjava . util . HashSet Ċ // Ġend :: imports [] Ċ Ċ import Ġio . mic ronaut . context . annotation . Requires Ċ Ċ @ Requires ( property Ġ= Ġ" spec . name ", Ġvalue Ġ= Ġ" Correlation Spec ") Ċ // Ġtag :: clazz [] Ċ @ Mqtt Subscriber Ċ class ĠProduct Listener Ġ{ ĊĊĠĠĠ Ġval Ġmessages : ĠMutable Set < String > Ġ= ĠCollections . synchronized Set ( HashSet ()) ĊĊĠĠĠ Ġ@ Topic (" product ") ĊĠĠĠ Ġfun Ġreceive (@ Correlation Ġdata : ĠByteArray ) Ġ{ Ġ// Ġ< 1 > ĊĠĠĠĠĠĠĠ Ġmessages . add ( String ( data , ĠStandard Charsets . UTF _ 8 )) ĊĠĠĠ Ġ} Ċ } Ċ // Ġend :: clazz [] Ċ