[
https://issues.apache.org/jira/browse/AMQ-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13082429#comment-13082429
]
Rasitha Wijesinghe commented on AMQ-2270:
-----------------------------------------
The same issue exists in 5.5 broker.
Just to note: Both 5.4.2 and 5.5 will show the message in the database once you
create the queue (Consumer.MyClient.VirtualTopic.FOO) manually. Then all
messages in the DB shows up in the queue. But the problem is, any message
published to the virtual topic since the restart is lost to that consumer
(until it connects next time which creates the queue).
With KahaDB this is not the case. It will correctly show the queue right after
the restart with existing messages so any newly published messages will
continue coming to the queue.
I'll open a new issue.
> Activemq lost messages on restart
> ---------------------------------
>
> Key: AMQ-2270
> URL: https://issues.apache.org/jira/browse/AMQ-2270
> Project: ActiveMQ
> Issue Type: Bug
> Affects Versions: 5.2.0
> Reporter: madderla prem kumar
> Assignee: Rob Davies
> Fix For: 5.3.0
>
>
> Hi ,
> Have two brokers in network AMQ1 and AMQ2 and have lots of virtual topics
> configured , Some consumers exists on some queues on AMQ1 and vice versa . On
> some queues AMQ2 have a consumers with a selector and hence consume a certain
> percentage of messages and the queue gets filled up every time my test
> program runs . After a certain number of test runs when the queues on AMQ2
> have about 2800 pending messages , I have observerd that the messages got
> forwarded over to AMQ1 though AMQ1 have no consumers on these queues .
> After certain point producer cannot send any more messages to AMQ1 and dint
> see any exceptions on the producer side (no activity on Queues in admin
> console) .
> Killed AMQ1 and tried to restart it , It took long time to restart and issued
> a kill command again and then restarted .
> Now all my pending messages on AMQ1 have disappeared and this is what i see
> on console during start up .
> INFO BrokerService - Using Persistence Adapter:
> AMQPersistenceAdapter(/home/prem/software/apache-activemq-5.2.0/data.1)
> INFO AMQPersistenceAdapter - AMQStore starting using directory:
> /home/prem/software/apache-activemq-5.2.0/data.1
> INFO KahaStore - Kaha Store using data directory
> /home/prem/software/apache-activemq-5.2.0/data.1/kr-store/state
> INFO AMQPersistenceAdapter - Active data files: []
> WARN AMQPersistenceAdapter - The ReferenceStore is not valid -
> recovering ...
> INFO KahaStore - Kaha Store successfully deleted data
> directory /home/prem/software/apache-activemq-5.2.0/data.1/kr-store/data
> INFO AMQPersistenceAdapter - Journal Recovery Started from:
> DataManager:(data-)
> INFO KahaStore - Kaha Store using data directory
> /home/prem/software/apache-activemq-5.2.0/data.1/kr-store/data
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
