Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save curious3/ae602d1c4277ddd3992e to your computer and use it in GitHub Desktop.
Save curious3/ae602d1c4277ddd3992e to your computer and use it in GitHub Desktop.
DirectConsumerNotAvailableException using wildfly-camel
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
<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>
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