You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by as...@apache.org on 2021/05/11 06:36:36 UTC
[camel-k] 03/33: fix(kamelets): optional error handler
This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch release-1.4.x
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 2292a3434bad3ea35f7a25b4bfd29d742e2764ef
Author: Pasquale Congiusti <pa...@gmail.com>
AuthorDate: Tue Mar 16 17:38:14 2021 +0100
fix(kamelets): optional error handler
---
pkg/controller/kameletbinding/common.go | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/pkg/controller/kameletbinding/common.go b/pkg/controller/kameletbinding/common.go
index 354dfa2..32d7182 100644
--- a/pkg/controller/kameletbinding/common.go
+++ b/pkg/controller/kameletbinding/common.go
@@ -79,9 +79,12 @@ func createIntegrationFor(ctx context.Context, c client.Client, kameletbinding *
if err != nil {
return nil, errors.Wrap(err, "could not determine sink URI")
}
- onError, err := bindings.Translate(bindingContext, bindings.EndpointContext{Type: v1alpha1.EndpointTypeErrorHandler}, kameletbinding.Spec.ErrorHandler)
- if err != nil {
- return nil, errors.Wrap(err, "could not determine error handler URI")
+ var onError *bindings.Binding
+ if kameletbinding.Spec.ErrorHandler.Ref != nil || kameletbinding.Spec.ErrorHandler.URI != nil {
+ onError, err = bindings.Translate(bindingContext, bindings.EndpointContext{Type: v1alpha1.EndpointTypeErrorHandler}, kameletbinding.Spec.ErrorHandler)
+ if err != nil {
+ return nil, errors.Wrap(err, "could not determine error handler URI")
+ }
}
steps := make([]*bindings.Binding, 0, len(kameletbinding.Spec.Steps))