if (log.isTraceEnabled()) { log.trace("Dropping transacted messages for channel " + channelID); }
   public void dropTransactedMessages(Serializable channelID, Serializable txID) throws SystemException   {      try      {         if (log.isTraceEnabled()) { log.trace("Current transaction: " + currentTransactionToString()); }         Connection conn = ds.getConnection();         String sql = "DELETE FROM TRANSACTIONAL_MESSAGE_REFERENCES WHERE " +                      "CHANNELID = '" + channelID + "' AND " +                      "TXID = '" + txID + "'";         conn.createStatement().executeUpdate(sql);         if (log.isTraceEnabled()) { log.trace(sql); }         conn.close();      }      catch(Throwable t)      {         log.error("Failed to drop transacted undelivered", t);         tm.setRollbackOnly();      }   }