log.info("==============Running job:" + this.getName());
log.info("==============Running fill job");
   public void run()   {                  Connection conn = null;            try      {         log.info("==============Running job:" + this.getName());                  super.setup();                  conn = cf.createConnection();                  long count = 0;                  Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);                  MessageProducer prod = sess.createProducer(dest);         prod.setDeliveryMode(deliveryMode);                  for (int i = 0; i < numMessages; i++)         {            Message m = mf.getMessage(sess, msgSize);            prod.send(m);            count++;         }                    log.info("==========================Finished running job");                 }      catch (Exception e)      {         log.error("Failed to fill destination", e);         failed = true;      }      finally      {         if (conn != null)         {            try            {               conn.close();            }            catch (Exception e)            {               log.error("Failed to close connection", e);               failed = true;            }         }      }   } 