1 Reply Latest reply on Feb 26, 2011 5:32 AM by henk53

    JMS bridge broken in 2.1.2/JBoss AS 6?

    henk53

      I was looking at the JMS bridge in JBoss AS 6 (HornetQ 2.1.2), and I think it's broken.

       

      When the bridge can't connect to the destinations at startup, a recovery procedure is started:

       

       

         if (ok)
            {
               // start the source connection
      
               sourceConn.start();
      
               started = true;
      
               if (maxBatchTime != -1)
               {
                  if (JMSBridgeImpl.trace)
                  {
                     JMSBridgeImpl.log.trace("Starting time checker thread");
                  }
      
                  timeChecker = new BatchTimeChecker();
      
                  executor.execute(timeChecker);
                  batchExpiryTime = System.currentTimeMillis() + maxBatchTime;
      
                  if (JMSBridgeImpl.trace)
                  {
                     JMSBridgeImpl.log.trace("Started time checker thread");
                  }
               }
      
               executor.execute(new SourceReceiver());
      
               if (JMSBridgeImpl.trace)
               {
                  JMSBridgeImpl.log.trace("Started " + this);
               }
            }
            else
            {
               JMSBridgeImpl.log.warn("Failed to start bridge");
               handleFailureOnStartup();
            }
      
      

       

      However, this failure handler only seems to set up JMS objects again and starts the connection. It does not start up either the BatchTimeChecker or the SourceReceiver.

       

      In effect, even after the bridge has successfully reconnected, the source destination keeps filling up and no messages are ever send to the target destination.

       

      Are there any plans to fix this for JBoss AS 6.1?