Method OnIntegrationMessage

pkg/registry/trigger.go:119–135

(ctx core.IntegrationMessageContext)

}

func (s *PanicableTrigger) OnIntegrationMessage(ctx core.IntegrationMessageContext) (err error) {
	defer func() {
		if r := recover(); r != nil {
			ctx.Logger.Errorf("Trigger %s panicked in OnIntegrationMessage(): %v\nStack: %s",
				s.underlying.Name(), r, debug.Stack())
			err = fmt.Errorf("trigger %s panicked in OnIntegrationMessage(): %v",
				s.underlying.Name(), r)
		}
	}()

	integrationTrigger, ok := s.underlying.(core.IntegrationTrigger)
	if !ok {
		return fmt.Errorf("trigger %s is not an integration trigger", s.underlying.Name())
	}

	return integrationTrigger.OnIntegrationMessage(ctx)
}