Read JSON serialized message body
Set consume timeout and use atomic types in signal handler