removed unnecessary close method
renamed avroSchema to avroCodec
implemented Avro decoding for watched messages