This method used to be really clean until I added the event hooks. Is there any cleaner way to code this?

Create method with event hooks

        public async Task<ICreateResponse<TEntity>> CreateAsync(TEntity poco)
        {
            bool exitMethod = false;

            //-- Event: Method start 
            var eventResult = OnCreate_MethodStart != null ? OnCreate_MethodStart(poco, out exitMethod) : null;
            if (exitMethod) { return eventResult; }

            try
            {
                var entityId = ReflectionHelper.GetPropertyValue(poco, _repoIdentityProperty);

                if (!string.IsNullOrWhiteSpace(entityId as string))
                {
                    // check for existance first!
                    var doc = await _repository.GetByIdAsync(entityId);

                    if (doc != null)
                    {
                        //-- Event: Already exists 
                        eventResult = OnCreate_HasConflict != null ? OnCreate_HasConflict(poco, out exitMethod) : null;
                        if (exitMethod) { return eventResult; }

                        return new ConflictResponse<TEntity>(entityId, poco);
                    }
                }

                //-- Event: Doc NOT exists, so create! 
                eventResult = OnCreate_NoConflict != null ? OnCreate_NoConflict(poco, out exitMethod) : null;
                if (exitMethod) { return eventResult; }

                var res = await _repository.CreateAsync(poco);
                var response = new CreateResponse<TEntity>(res);

                //-- Event: Successful execution
                eventResult = OnCreate_Success != null ? OnCreate_Success(poco, out exitMethod) : null;
                if (exitMethod) { return eventResult; }

                return response;
            }
            catch (Exception ex)
            {
                //-- Event: Error during create
                eventResult = OnCreate_Exception != null ? OnCreate_Exception(poco, out exitMethod) : null;
                if (exitMethod) { return eventResult; }

                return new CreateErrorResponse<TEntity>(poco, ErrorMessage.Build("Create", poco.ToString()), ex);
            }
        }