package Ġcom . cz f . udp Ċ Ċ import Ġcom . cz f . tcp . UDP Companion Ċ import Ġcom . cz f . tcp . UDP Message Ċ import Ġorg . springframework . beans . factory . annotation . Value Ċ import Ġorg . springframework . context . annotation . Bean Ċ import Ġorg . springframework . context . annotation . Configuration Ċ import Ġorg . springframework . integration . annotation . Service Activator Ċ import Ġorg . springframework . integration . annotation . Transformer Ċ import Ġorg . springframework . integration . ip . udp . Un icast Re ceiving Channel Adapter Ċ import Ġorg . springframework . messaging . Message Ċ Ċ @ Configuration Ċ class ĠUDP Controller Ġ{ ĊĠĠĠ Ġ@ Value ("\ ${ udp . port }") ĊĠĠĠ Ġprivate Ġvar Ġport Ġ= Ġ 1 2 3 4 5 ĊĊĠĠĠ Ġ@ Bean ĊĠĠĠ Ġfun Ġget Un icast Re ceiving Channel Adapter (): ĠUn icast Re ceiving Channel Adapter Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠUn icast Re ceiving Channel Adapter ( port ). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġset Output Channel Name (" udp ") ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Transformer ( input Channel Ġ= Ġ" udp ", Ġoutput Channel Ġ= Ġ" udp String ") ĊĠĠĠ Ġfun Ġtransformer ( message : ĠMessage < *> ): ĠString ? Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠString (( message . payload Ġas ĠByteArray )) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Service Activator ( input Channel =" udp String ") ĊĠĠĠ Ġfun Ġsave ( message : ĠString ) Ġ{ ĊĠĠĠĠĠĠĠ Ġprintln ( message ) ĊĠĠĠĠĠĠĠ ĠUDP Companion . message Queue . add ( UDP Message ( message )) ĊĠĠĠ Ġ} Ċ }