Re: Exception while trying to gracefully shutdown camel

Fri, 28 May 2010 05:14:36 -0700 

Can you create a small test case and attached with a Camel JIRA[1]?
In this way we can dig the issue more easily.

[1] https://issues.apache.org/activemq/browse/CAMEL

Willem
vcheruvu wrote:

I am using Spring 2.5.6.


Claus Ibsen-2 wrote:

Hi

What version of Spring are you using?



On Fri, May 28, 2010 at 11:34 AM, vcheruvu <[email protected]>
wrote:

K.. I have gone through Spring reference manual and looked at ways to
control
bean destroy. I tried using camelcontext id name defined in my config and
applied it to bean's depends-on attribute.  Unfortunately, spring cannot
find my camelcontext id name.  After some investigation, I came across
this
link in Camel forum,

http://old.nabble.com/Spring-3.0-and-Camel-2.2---Route-configure%28%29-called-before-Spring-beans-injected-td28415437.html#a28415437

It appears only camelcontext id name "camel"  can be recognized by Spring
but not my custom camelcontext ids.  Camel hasn't registered my
camelcontext
ids in Spring. Is there any other way to make bean depend on Camel route
through Spring DSL ?



Claus Ibsen-2 wrote:

Hi

I wonder if Spring has shutdown some of the JPA beans before it ask
Camel to shutdown.
So you may have to add some options on the spring beans. I wonder if
the depends-on="camel" Spring attribute can be used so Spring will
shutdown those spring beans AFTER camel.

On Thu, May 27, 2010 at 5:21 AM, vcheruvu <[email protected]>
wrote:

Hi,

I am performing graceful shutdown test with our application.This is to
ensure Camel does process all of the messages from VM queue and
shutdown
our
application. So, our application reads data from tables as a queue
using
Camel-JPA Component. Please see my camel spring config in the
attachment
below. I have ensured VM queue has about 100,000 Exchanges to be
processed
by storeNewOrderEventEntity route.  I tried to gracefully shut down
Camel
from eclipse stop button. In doing so, I got error with
saveOrderEventRepository bean (this bean calls our DAO/repository layer
code
which calls store procedure at DB server to insert new records).

Any idea how I can ensure this bean can defer getting destroyed and
ensure
all messages are processed before shutting down?

http://old.nabble.com/file/p28689054/pats-camel-context.xml
pats-camel-context.xml

2010-05-27 11:24:40,915 ERROR [Camel thread 139:
vm://storeNewEntity?concurrentConsumers=100&size=1000000&timeout=1000000]
Logger.log:248 - Err
or processing exchange. Exchange[Message: OrderEventDTO
[AccountID=IGMKTS,
AdviserID=IGORDERS2, BrokerID=MQIGM, BuySell=SELL, ClOrdID=null, ClO
rdIDString=195, ClientCode=Y (DR), ComfirmationID=null,
ContractID=6875,
CustomerOrderID=MQIGM, EventTyp
eCode=Partially Filled, ExchangeOrderID=20100413PTSGW0Y,
ExecID=6813:3641289, ExecutionInstructionCode=Market, ExpireTime=null,
ExternalOrderID
=1956282, FillContractID=null, FillPrice=null, FillSubaccountID=null,
FillVolume=null, HasChildren=null, OrderCategoryCode=Native,
OrderDate=20
10-04-13 07:29:13.0, OrderTypeCode=F, ParentClOrdID=null,
ParentClOrdIDString=null, Price=1986.75, ReferenceClOrdID=null,
ReferenceClOrdIDStrin
g=null, ReferenceExecID=null, ReferenceTradeDate=2010-04-13 07:29:13.0,
SourceSystem=PATS, StopPrice=0.0, TargetSystem=CME, Text= , TimeInForce
Code=Limit, TransactTime=2010-04-13 07:29:13.0, Volume=23,
ExternalSecondaryID=6320]]. Caused by:
[org.springframework.beans.factory.BeanCreationNotAllowedException -
Error
creating bean with name 'saveOrderEventRepository': Singleton bean
creation
not allowed while the singletons of t
his factory are in destruction (Do not request a bean from a
BeanFactory
in
a destroy method implementation!)]
org.springframework.beans.factory.BeanCreationNotAllowedException:
Error
creating bean with name 'saveOrderEventRepository': Singleton bean
creation
not allowed while the singletons of this factory are in destruction (Do
not
request a bean from a BeanFactory in a destroy method implementation!)
       at
org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:209)
       at
org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:261)
       at
org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)
       at
org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)
       at
org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:880)
       at
org.apache.camel.spring.spi.ApplicationContextRegistry.lookup(ApplicationContextRegistry.java:52)
       at
org.apache.camel.component.bean.RegistryBean.lookupBean(RegistryBean.java:125)
       at
org.apache.camel.component.bean.RegistryBean.getBean(RegistryBean.java:56)
       at
org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:72)
       at
org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:95)
       at
org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:65)
       at
org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97)
       at
org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95)
       at
org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146)
       at
org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94)
       at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82)
       at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
       at
org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
       at
org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
       at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:93)
       at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
       at
org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
       at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
       at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
       at
org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
--
View this message in context:
http://old.nabble.com/Exception-while-trying-to-gracefully-shutdown-camel-tp28689054p28689054.html
Sent from the Camel - Users mailing list archive at Nabble.com.





--
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus



--
View this message in context:
http://old.nabble.com/Exception-while-trying-to-gracefully-shutdown-camel-tp28689054p28704698.html
Sent from the Camel - Users mailing list archive at Nabble.com.





--
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus

Reply via email to