Uploaded image for project: 'ActiveMQ'
  1. ActiveMQ
  2. AMQ-4783

Scheduled messages lost if broker is shut down during the scheduled time of the message

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Minor
    • Resolution: Duplicate
    • Affects Version/s: 5.8.0
    • Fix Version/s: 5.9.0
    • Component/s: Broker
    • Labels:
      None

      Description

      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

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                Mrityunjoy Mrityunjoy Roy
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: