Created
January 7, 2015 07:08
-
-
Save curious3/ae602d1c4277ddd3992e to your computer and use it in GitHub Desktop.
DirectConsumerNotAvailableException using wildfly-camel
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2015-01-06 22:53:43,124 DEBUG [org.apache.camel.impl.DefaultComponentResolver] (default task-1) Found component: direct in registry: null | |
| 2015-01-06 22:53:43,125 DEBUG [org.apache.camel.impl.DefaultComponentResolver] (default task-1) Found component: direct via type: org.apache.camel.component.direct.DirectComponent via: META-INF/services/org/apache/camel/component/direct | |
| 2015-01-06 22:53:43,126 DEBUG [org.apache.camel.management.DefaultManagementAgent] (default task-1) Registered MBean with ObjectName: org.apache.camel:context=camel-3,type=components,name="direct" | |
| 2015-01-06 22:53:43,126 DEBUG [org.apache.camel.impl.DefaultComponent] (default task-1) Creating endpoint uri=[direct://start], path=[start] | |
| 2015-01-06 22:53:43,126 DEBUG [org.apache.camel.cdi.CdiCamelContext] (default task-1) direct://start converted to endpoint: Endpoint[direct://start] by component: org.apache.camel.component.direct.DirectComponent@40f840ed | |
| 2015-01-06 22:53:43,129 DEBUG [org.apache.camel.component.direct.DirectProducer] (default task-1) Starting producer: Producer[direct://start] | |
| 2015-01-06 22:53:43,129 DEBUG [org.apache.camel.impl.ProducerCache] (default task-1) Adding to producer cache with key: Endpoint[direct://start] for producer: Producer[direct://start] | |
| 2015-01-06 22:53:43,132 DEBUG [org.apache.camel.impl.ProducerCache] (default task-1) >>>> Endpoint[direct://start] Exchange[Message: jdoe] | |
| 2015-01-06 22:53:43,139 ERROR [io.undertow.request] (default task-1) UT005023: Exception handling request to /camel/test: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[Message: jdoe] | |
| at org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1380) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.util.ExchangeHelper.extractResultBody(ExchangeHelper.java:623) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:471) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:133) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:149) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.DefaultProducerTemplate.requestBody(DefaultProducerTemplate.java:301) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.DefaultProducerTemplate.requestBody(DefaultProducerTemplate.java:331) [camel-core-2.14.1.jar:2.14.1] | |
| at com.sample.ServiceServlet.doGet(ServiceServlet.java:41) [classes:] | |
| at javax.servlet.http.HttpServlet.service(HttpServlet.java:687) [jboss-servlet-api_3.1_spec-1.0.0.Final.jar:1.0.0.Final] | |
| at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) [jboss-servlet-api_3.1_spec-1.0.0.Final.jar:1.0.0.Final] | |
| at io.undertow.servlet.handlers.ServletHandler.handleRequest(ServletHandler.java:85) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.security.ServletSecurityRoleHandler.handleRequest(ServletSecurityRoleHandler.java:61) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.ServletDispatchingHandler.handleRequest(ServletDispatchingHandler.java:36) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at org.wildfly.extension.undertow.security.SecurityContextAssociationHandler.handleRequest(SecurityContextAssociationHandler.java:78) | |
| at io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.security.SSLInformationAssociationHandler.handleRequest(SSLInformationAssociationHandler.java:131) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.security.ServletAuthenticationCallHandler.handleRequest(ServletAuthenticationCallHandler.java:56) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.security.handlers.AbstractConfidentialityHandler.handleRequest(AbstractConfidentialityHandler.java:45) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.security.ServletConfidentialityConstraintHandler.handleRequest(ServletConfidentialityConstraintHandler.java:63) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.security.handlers.AuthenticationMechanismsHandler.handleRequest(AuthenticationMechanismsHandler.java:58) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.security.CachedAuthenticatedSessionHandler.handleRequest(CachedAuthenticatedSessionHandler.java:70) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.security.handlers.SecurityInitialHandler.handleRequest(SecurityInitialHandler.java:76) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at org.wildfly.extension.undertow.security.jacc.JACCContextIdHandler.handleRequest(JACCContextIdHandler.java:61) | |
| at io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.ServletInitialHandler.handleFirstRequest(ServletInitialHandler.java:261) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.ServletInitialHandler.dispatchRequest(ServletInitialHandler.java:247) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.ServletInitialHandler.access$000(ServletInitialHandler.java:76) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.servlet.handlers.ServletInitialHandler$1.handleRequest(ServletInitialHandler.java:166) [undertow-servlet-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.server.Connectors.executeRootHandler(Connectors.java:197) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at io.undertow.server.HttpServerExchange$1.run(HttpServerExchange.java:759) [undertow-core-1.1.0.Final.jar:1.1.0.Final] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [rt.jar:1.7.0_17] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [rt.jar:1.7.0_17] | |
| at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_17] | |
| Caused by: org.apache.camel.component.direct.DirectConsumerNotAvailableException: No consumers available on endpoint: Endpoint[direct://start]. Exchange[Message: jdoe] | |
| at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:47) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:74) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:375) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:343) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:233) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:343) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:201) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:128) [camel-core-2.14.1.jar:2.14.1] | |
| at org.apache.camel.impl.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:132) [camel-core-2.14.1.jar:2.14.1] | |
| ... 32 more |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <beans xmlns="http://www.springframework.org/schema/beans" | |
| xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | |
| xsi:schemaLocation=" | |
| http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd | |
| http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd | |
| http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"> | |
| <camelContext id="test-context" xmlns="http://camel.apache.org/schema/spring"> | |
| <route> | |
| <from uri="direct:start" /> | |
| <log logName="sample" loggingLevel="INFO" | |
| message="request received: ${body}" /> | |
| <transform> | |
| <simple>Hello #{body}</simple> | |
| </transform> | |
| </route> | |
| </camelContext> | |
| </beans> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.sample; | |
| import java.io.IOException; | |
| import javax.inject.Inject; | |
| import javax.servlet.ServletConfig; | |
| import javax.servlet.ServletException; | |
| import javax.servlet.ServletOutputStream; | |
| import javax.servlet.annotation.WebServlet; | |
| import javax.servlet.http.HttpServlet; | |
| import javax.servlet.http.HttpServletRequest; | |
| import javax.servlet.http.HttpServletResponse; | |
| import org.apache.camel.CamelContext; | |
| import org.apache.camel.ProducerTemplate; | |
| import org.apache.camel.cdi.ContextName; | |
| @SuppressWarnings("serial") | |
| @WebServlet(name = "ServiceServlet", urlPatterns = { "/*" }, loadOnStartup = 1) | |
| public class ServiceServlet extends HttpServlet { | |
| @Inject | |
| @ContextName("test-context") | |
| private CamelContext camelctx; | |
| private ProducerTemplate producer; | |
| @Override | |
| public void init(ServletConfig config) throws ServletException { | |
| super.init(config); | |
| producer = camelctx.createProducerTemplate(); | |
| } | |
| @Override | |
| protected void doGet(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException { | |
| String name = req.getParameter("name"); | |
| if (name == null || "".equals(name.trim())) { | |
| throw new ServletException("Requires request parameter 'name'"); | |
| } | |
| String result = producer.requestBody("direct:start", name, String.class); | |
| ServletOutputStream out = res.getOutputStream(); | |
| out.print(result); | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment