activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Christopher G. Stach II" <...@ldsys.net>
Subject Re: Problems with VM transport
Date Mon, 26 Mar 2007 03:11:36 GMT
uma_rk@comcast.net wrote:
> Hello...
> 
> I have a couple of basic questions on ActiveMQ. I would appreciate any hits as I am stuck.
> 
> I am using ActiveMQ 4.1 with JDK6.
> 
> 1) When I use an embedded broker with vm transport (vm://localhost)
> the instantiation of my Spring SimpleMessageListenerContainer
> always fails with a JournalLockedException.
> 
> What does this exception mean exactly? I understand this has something to do with 
> persistance of message (since that is on by default). While I do not 
> care to enable persistance and would like to turn it off, I would still
> like to understand what causes this exception:
> 
> org.springframework.beans.factory.BeanCreationException: Error creating bean with name
'DmmStartupMessageListener' defined in class path resource [contexts/bus/DmsStandardSubscriptions.xml]:
Invocation of init method failed; nested exception is java.lang.NoClassDefFoundError: org/apache/activeio/journal/active/JournalLockedException
> Caused by:
> java.lang.NoClassDefFoundError: org/apache/activeio/journal/active/JournalLockedException
>         at org.apache.activemq.broker.BrokerService.createPersistenceFactory(BrokerService.java:1328)
>         at org.apache.activemq.broker.BrokerService.getPersistenceFactory(BrokerService.java:544)
>         at org.apache.activemq.broker.BrokerService.createPersistenceAdapter(BrokerService.java:1320)
>         at org.apache.activemq.broker.BrokerService.getPersistenceAdapter(BrokerService.java:631)
>         at org.apache.activemq.broker.BrokerService.createRegionBroker(BrokerService.java:1250)
>         at org.apache.activemq.broker.BrokerService.createBroker(BrokerService.java:1209)
>         at org.apache.activemq.broker.BrokerService.getBroker(BrokerService.java:508)
>         at org.apache.activemq.broker.BrokerService.start(BrokerService.java:394)
>         at org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConnect(VMTransportFactory.java:113)
>         at org.apache.activemq.transport.vm.VMTransportFactory.doConnect(VMTransportFactory.java:52)
>         at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:43)
>         at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:77)
>         at org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:227)
> 
> 
> 2) Which jarfile contains the exception class  org/apache/activeio/journal/active/JournalLockedException?
> 
> 3) How do I use an embedded broker without persistance?
> 
> The URL
> 
>     vm://localhost?persistant=false
> 
> fails with an exception that says that the    option is illegal.
> 
> 4) Once the broker is up, could I dynamically (programmatically) change the
> broker URL by augmenting the broker URL with a failover URL as follows?
> 
>    Startup:   vm://localhost
>    During runtime (after an event): 
>            failover(vm://localhost,tcp://remote:61616)
> 
>   Would modifying the broker URL of the connection factory cause problems?
> 
> Thanks,
> 
> /U

This was kind of like watching a retarded kid fall down, and laughing...
but three times in a row.  Thanks.

-- 
Christopher G. Stach II


Mime
View raw message