log.error("!!!!!!!!!!!!!!!Receiver failed", e);
log.error("Receiver failed", e); throwable = e;
      public void run()      {         try         {            int count = 0;                        while (count < (numMessages))            {                                                         Message m = cons.receive(RECEIVE_TIMEOUT);                                       if (m != null)               {                  count++;                  if (transacted)                  {                     if (count % transactionSize == 0)                     {                        sess.commit();                     }                  }                }                   else               {                  log.error("!!!!!!!!!!!!!!Failed to receive messages!!!!");                  failed = true;                  break;               }                                                                     }           }         catch (Exception e)         {            log.error("!!!!!!!!!!!!!!!Receiver failed", e);            failed = true;         }      }