[
https://issues.apache.org/jira/browse/AMQ-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mrityunjoy Roy updated AMQ-4783:
--------------------------------
Priority: Minor (was: Major)
> Scheduled messages lost if broker is shut down during the scheduled time of
> the message
> ---------------------------------------------------------------------------------------
>
> Key: AMQ-4783
> URL: https://issues.apache.org/jira/browse/AMQ-4783
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.8.0
> Reporter: Mrityunjoy Roy
> Priority: Minor
>
> a. Send a scheduled message to broker , let us say to deliver in 60 sec
> b. Immediately shut down the broker and keep it down for 60 seconds (down
> at the time the message is scheduled to deliver)
> On coming up , the message is not queued .
> When the broker starts , it adds listeners to it’s store
> 2013-04-18 19:35:42,184 INFO Broker starter
> activemq.broker.BrokerService:633 - Apache ActiveMQ 5.8.0 (authorizerBroker,
> ID:Joycomp-4951-1366328140528-1:1) is starting
> 2013-04-18 19:35:42,199 DEBUG Broker starter
> kahadb.scheduler.JobSchedulerImpl:82 - Joy - Adding job listener
> 2013-04-18 19:35:42,215 DEBUG Broker starter
> kahadb.scheduler.JobSchedulerImpl:85 - Joy - Added Listener is scheduler
> broker
> After that when message’s scheduld time comes , it fires the message to queue
> as below -:
> 2013-04-18 19:37:41,012 DEBUG JobScheduler:JMS
> kahadb.scheduler.JobSchedulerImpl:442 - Firing Job
> [id=ID:Joycomp-4951-1366328140528-5:1:1:1:1, startTime=Thu Apr 18 19:37:36
> EDT 2013, delay=5000, period=0, repeat=0, nextTime=Thu Apr 18 19:37:41 EDT
> 2013]
> 2013-04-18 19:37:41,012 DEBUG JobScheduler:JMS
> kahadb.scheduler.JobSchedulerImpl:445 - byte sequnce =
> org.apache.activemq.util.ByteSequence@f0c67
> 2013-04-18 19:37:41,012 DEBUG JobScheduler:JMS
> kahadb.scheduler.JobSchedulerImpl:446 - Job listeners list=1
> Now , for my case , on a restart , if it finds that a message’s scheduled
> time is past the time of start of the broker , during the initialization it
> fires the message even before the broker is started
> 2013-04-18 19:40:57,387 INFO Broker starter kahadb.plist.PListStoreImpl:331
> -
> PListStore:[C:\Joy\servers\tomcat\7.0.37\dist\bin\activemq-data\authorizerBroker\tmp_storage]
> started
> 2013-04-18 19:40:58,356 DEBUG JobScheduler:JMS
> kahadb.scheduler.JobSchedulerImpl:445 - byte sequnce =
> org.apache.activemq.util.ByteSequence@10ee5b8
> 2013-04-18 19:40:58,356 DEBUG JobScheduler:JMS
> kahadb.scheduler.JobSchedulerImpl:446 - Job listeners list=0
> // Broker started later -:
> 2013-04-18 19:40:59,199 INFO Broker starter
> activemq.broker.BrokerService:633 - Apache ActiveMQ 5.8.0 (authorizerBroker,
> ID:Joycomp-1494-1366328458231-1:1) is starting
> 2013-04-18 19:40:59,246 DEBUG Broker starter
> kahadb.scheduler.JobSchedulerImpl:82 - Joy - Adding job listener
> 2013-04-18 19:40:59,246 DEBUG Broker starter
> kahadb.scheduler.JobSchedulerImpl:85 - Joy - Added Listener is scheduler
> broker
--
This message was sent by Atlassian JIRA
(v6.1#6144)
