You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Mrityunjoy Roy (JIRA)" <ji...@apache.org> on 2013/10/04 00:46:42 UTC
[jira] [Updated] (AMQ-4783) Scheduled messages lost if broker is
shut down during the scheduled time of the message
[ 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)