Kaha Persistence in incubator-activemq-4.1-20060710.071829-11

[Eugene Prokopiev]

Hi,

I use incubator-activemq-4.1-20060710.071829-11 with this config:
<beans xmlns="http://activemq.org/config/1.0";>

    <broker useJmx="true" persistent="false" populateJMSXUserID="true">

        <transportConnectors>
            <transportConnector name="default" uri="tcp://localhost:61616"/>
        </transportConnectors>
        
        <persistenceAdapter>
            <kahaPersistentAdaptor dir = "/tmp/activemq-data"/>
        </persistenceAdapter>
        
    </broker>

</beans>

On startup I got:

$ sh activemq
ACTIVEMQ_HOME: /home/john/devel/java/jms/incubator-activemq-4.1-SNAPSHOT
Loading message broker from: xbean:activemq.xml
ERROR: java.lang.RuntimeException: Failed to execute start task. Reason: 
org.springframework.beans.factory.BeanCreationException: Error creating 
bean with name 'org.apache.activemq.xbean.XBeanBrokerService' defined in 
class path resource [activemq.xml]: Cannot create inner bean 
'org.apache.activemq.store.kahadaptor.KahaPersistentAdaptor' while 
setting bean property 'persistenceAdapter'; nested exception is 
org.springframework.beans.factory.UnsatisfiedDependencyException: Error 
creating bean with name 
'org.apache.activemq.store.kahadaptor.KahaPersistentAdaptor' defined in 
class path resource [activemq.xml]: Unsatisfied dependency expressed 
through constructor argument with index 0 of type [java.io.File]: Could 
not convert constructor argument value [/tmp/activemq-data] to required 
type [java.io.File]: Failed to convert value of type [java.lang.String] 
to required type [java.io.File]; nested exception is 
java.lang.IllegalArgumentException: Could not retrieve File for class 
path resource [/tmp/activemq-data]: class path resource 
[/tmp/activemq-data] cannot be resolved to URL because it does not exist
java.lang.RuntimeException: Failed to execute start task. Reason: 
org.springframework.beans.factory.BeanCreationException: Error creating 
bean with name 'org.apache.activemq.xbean.XBeanBrokerService' defined in 
class path resource [activemq.xml]: Cannot create inner bean 
'org.apache.activemq.store.kahadaptor.KahaPersistentAdaptor' while 
setting bean property 'persistenceAdapter'; nested exception is 
org.springframework.beans.factory.UnsatisfiedDependencyException: Error 
creating bean with name 
'org.apache.activemq.store.kahadaptor.KahaPersistentAdaptor' defined in 
class path resource [activemq.xml]: Unsatisfied dependency expressed 
through constructor argument with index 0 of type [java.io.File]: Could 
not convert constructor argument value [/tmp/activemq-data] to required 
type [java.io.File]: Failed to convert value of type [java.lang.String] 
to required type [java.io.File]; nested exception is 
java.lang.IllegalArgumentException: Could not retrieve File for class 
path resource [/tmp/activemq-data]: class path resource 
[/tmp/activemq-data] cannot be resolved to URL because it does not exist
        at 
org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:69)
        at 
org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:49)
        at 
org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:81)
        at 
org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:49)
        at 
org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:45)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
        at java.lang.reflect.Method.invoke(Method.java:585)
        at org.apache.activemq.console.Main.runTaskClass(Main.java:135)
        at org.apache.activemq.console.Main.main(Main.java:67)
...

I tried to create /tmp/activemq-data directory by hand but after 
starting AMQ and sending 1000 messages I see this:

$ du /tmp/amq-data/
416K    /tmp/amq-data/kaha.db
420K    /tmp/amq-data/

So, thre are no messages recieved after AMQ restarting :(

--
Thanks,
Eugene Prokopiev