package Ġcom . k am ij ou c en . c en im . service . manager Ċ Ċ import Ġcom . k am ij ou c en . c en im . message . msg . util . IM Consumer Ċ import Ġcom . k am ij ou c en . c en im . message . msg .* Ċ import Ġcom . k am ij ou c en . c en im . service . process . connect Msg Process Ċ import Ġorg . apache . commons . logging . Log Factory Ċ import Ġorg . springframework . stereotype . Component Ċ import Ġjava . util . concurrent . Concurrent HashMap Ċ Ċ @ Component Ċ class ĠService Msg Process Manager Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġlog Ġ= ĠLog Factory . getLog (" Service Msg Parse Manager ") ĊĊĠĠĠ Ġprivate Ġval Ġprocess Map Ġ= ĠConcurrent HashMap < Int , ĠIM Consumer >() ĊĊĠĠĠ Ġinit Ġ{ ĊĠĠĠĠĠĠĠ ĠMessage Body Type . values (). forEach Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġwhen Ġ( it . type ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠMessage Body Type . CONNECT _ MSG . type Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprocess Map [ Message Body Type . CONNECT _ MSG . type ] Ġ= Ġconnect Msg Process () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget Process ( type : ĠInt ) Ġ= Ġprocess Map [ type ] Ċ Ċ }