Return-Path: Delivered-To: apmail-camel-dev-archive@www.apache.org Received: (qmail 17022 invoked from network); 29 Jun 2010 21:11:18 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 29 Jun 2010 21:11:18 -0000 Received: (qmail 11696 invoked by uid 500); 29 Jun 2010 21:11:18 -0000 Delivered-To: apmail-camel-dev-archive@camel.apache.org Received: (qmail 11516 invoked by uid 500); 29 Jun 2010 21:11:18 -0000 Mailing-List: contact dev-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list dev@camel.apache.org Received: (qmail 11480 invoked by uid 500); 29 Jun 2010 21:11:17 -0000 Delivered-To: apmail-activemq-camel-dev@activemq.apache.org Received: (qmail 11476 invoked by uid 99); 29 Jun 2010 21:11:17 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 29 Jun 2010 21:11:17 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.22] (HELO thor.apache.org) (140.211.11.22) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 29 Jun 2010 21:11:14 +0000 Received: from thor (localhost [127.0.0.1]) by thor.apache.org (8.13.8+Sun/8.13.8) with ESMTP id o5TLArKA006009 for ; Tue, 29 Jun 2010 21:10:53 GMT Message-ID: <23156506.27721277845853338.JavaMail.jira@thor> Date: Tue, 29 Jun 2010 17:10:53 -0400 (EDT) From: "Michael Chen (JIRA)" To: camel-dev@activemq.apache.org Subject: [jira] Issue Comment Edited: (CAMEL-2854) No consumers available on "direct://xyz" endpoint In-Reply-To: <11199501.23841277423272294.JavaMail.jira@thor> MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/activemq/browse/CAMEL-2854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=60346#action_60346 ] Michael Chen edited comment on CAMEL-2854 at 6/29/10 5:08 PM: -------------------------------------------------------------- Here how the route is built: from("direct:UserCancelJobRequest").process(new Processor() { public void process(Exchange exchange) throws Exception { .... } }). to("direct:JobRunInstanceUpdate"). ... We use dynamically constructed routing slip or template to send messages to the "direct:UserCancelJobRequest" endpoint. There should always be consumer for this. Otherwise Camel would be to unpredictable to use. That is real bug that needs to be fixed. Thanks --Michael was (Author: mwc_tonesoft): Here how the route is built: from("direct:UserCancelJobRequest").process(new Processor() { public void process(Exchange exchange) throws Exception { .... } }). to("direct:JobRunInstanceUpdate"). ... We use dynamically constructed routing slip or template to send messages to the "direct:UserCancelJobRequest" endpoint. There should always be consumer for this. Otherwise Camel would be to unpredictable to use. That is real bug that needs to be fixed. Thanks --Michael > No consumers available on "direct://xyz" endpoint > ------------------------------------------------- > > Key: CAMEL-2854 > URL: https://issues.apache.org/activemq/browse/CAMEL-2854 > Project: Apache Camel > Issue Type: Bug > Components: camel-core > Affects Versions: 2.2.0 > Environment: ActiveMQ 5.3.2 / Camel 2.2.0 > Reporter: Michael Chen > Assignee: Claus Ibsen > Priority: Critical > Fix For: 2.4.0 > > > The following warning in log4j log shows up with no predictable reason: > 2010-06-24 14:07:01,090 WARN [DefaultMessageListenerContainer-7:DirectProducer.java:42] No consumers available on endpoint: Endpoint[direct://UserCancelJobRequest] to process: Exchange[JmsMessage: RunnerBase{locationToRunId='DV02YcABTE43HTRPATEGCBFk0m0', jobrun_id=1234, requestOrigId='null', secretKey='null', replyToQueueOrTopic='null', corrolationId='null', requestCreationTime=Thu Jun 24 14:07:01 PDT 2010}] > The endpoint [direct://UserCancelJobRequest] could be a number of different endpoints in our application and all of them are of "direct:" type. When this happens, all messages that run through that endpoint will fail, and it will never recover unless the application is restarted. > Also, if I restart the application and use that route immediately, that warning will not occur and the request will finish successfully. It seems to happen to routes that have not been used for a while after startup. > When this happens, I can find the exact Camel endpoint/route/processor in JConsole, and nothing seems to be wrong. How can a "direct:" endpoint runs out of consumer? Isn't the thread that product this warning THE thread to process the message? > We recently upgraded from 5.2 to 5.3.2 and this starts to show up randomly. It is a show stopper! > --Michael -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.