Use observer on correlationId