Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Unable to send message to knative channel #483

Closed
kameshsampath opened this issue Feb 22, 2019 · 1 comment
Closed

Unable to send message to knative channel #483

kameshsampath opened this issue Feb 22, 2019 · 1 comment

Comments

@kameshsampath
Copy link
Contributor

kameshsampath commented Feb 22, 2019

Platform: minikube
kamel: master

When deploying route that sends data to a knative channel like:

from("amqp:queue:examples")
                .streamCaching()
                .log(LoggingLevel.INFO, "Object FQN ${header.objectFQN} Split Size: ${header.CamelSplitSize}")
                .aggregate(header("objectFQN"), this::listAggregate)
                .eagerCheckCompletion()
                .completion(exchange -> exchange.getIn().getHeader("CamelSplitSize") != null
                        && exchange.getIn().getHeader("CamelSplitSize", Long.class) > 0)
                .completionTimeout(7000)
                .process(exchange -> {
                    List<String> words = exchange.getIn().getBody(List.class);
                    words.sort(String::compareToIgnoreCase);
                    exchange.getIn().setBody( String.join(",",words).getBytes());

                })
                .log("Sending Body: ${body}")
                .to("knative:channel/sortucase")
                .end();

the message send fails with error

https://gist.github.com/kameshsampath/ea9c8b355bc82110d3d70b1a718598e5

@kameshsampath
Copy link
Contributor Author

kameshsampath commented Feb 25, 2019

It was bug with CoreDNS on kubernetes v1.11.0 on minikube., it got resolved upgrading minikube to v1.12.0.

Ref: knative/serving#3067

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant