activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rasitha Wijesinghe (JIRA)" <>
Subject [jira] [Commented] (AMQ-2270) Activemq lost messages on restart
Date Wed, 10 Aug 2011 16:07:32 GMT


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:
>             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
> 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:


View raw message