@ Override public ConcurrentMap < String , Object > deserializeAttributes ( final byte [ ] in ) { final InputStreamReader inputStream = new InputStreamReader ( new ByteArrayInputStream ( in ) ) ; if ( LOG . isDebugEnabled ( ) ) { LOG . debug ( "deserialize the stream" ) ; } try { return deserializer . deserializeInto ( inputStream , new ConcurrentHashMap < String , Object > ( ) ) ; } catch ( final RuntimeException e ) { LOG . warn ( "Caught Exception deserializing JSON " + e ) ; throw new TranscoderDeserializationException ( e ) ; } }
Return the deserialized map