// *********************************************
// *********FROM ForumManager CLASS*************
// *********************************************

    public static Msg saveMessage(Msg msg) throws Exception {
        PersistenceBroker broker = ojbHelper.getBroker();
        try {
            ojbHelper.beginTransaction(broker);

            broker.store(msg);

            Criteria criteria = new Criteria();
            criteria.addEqualTo(V_msg.MSG_ID, "" + msg.getMsg_id());

            Query query = new QueryByCriteria(V_msg.class, criteria);
            Collection msgs = broker.getCollectionByQuery(query);
            for (Object msg1 : msgs) {
                V_msg vm = (V_msg) msg1;
                log.debug("Removing msg " + msg.getMsg_id() + " from V_msg cache");
                broker.removeFromCache(vm);
            }
            ojbHelper.commitTransaction(broker);
            BaseManager.flushClassFromCache(V_forum_overview.class);
        } catch (Exception e) {
            log.error("Error createmsg()", e);
            ojbHelper.abortTransaction(broker);
        } finally {
            ojbHelper.closeBroker(broker);
        }
        return msg;
    }

    public static Msgthread saveThread(Msgthread msg) throws Exception {
        PersistenceBroker broker = ojbHelper.getBroker();
        try {
            ojbHelper.beginTransaction(broker);
            broker.store(msg);
            ojbHelper.commitTransaction(broker);
        } catch (Exception e) {
            log.error("Error createmsg()", e);
            ojbHelper.abortTransaction(broker);
        } finally {
            ojbHelper.closeBroker(broker);
        }
        return msg;
    }


// *********************************************
// ******FROM ForumManagerSingleton CLASS*******
// *********************************************

  public Msg saveMessage(Msg msg) throws Exception {
    PersistenceBroker broker = ojbHelper.getBroker();
    // now perform persistence operations
    try {
      ojbHelper.beginTransaction(broker);
      broker.store(msg);
      Criteria criteria = new Criteria();
      criteria.addEqualTo(V_msg.MSG_ID, "" + msg.getMsg_id());
      Collection msgs = ojbHelper.getCollectionByCriteria(V_msg.class, criteria);
      for (Object msg1 : msgs) {
        V_msg vm = (V_msg) msg1;
        log.debug("Removing msg " + msg.getMsg_id() + " from V_msg cache");
        broker.removeFromCache(vm);
      }
      ojbHelper.commitTransaction(broker);
      BaseManager.flushClassFromCache(V_forum_overview.class);
    } catch (Exception e) {
      log.error("Error createmsg()", e);
      ojbHelper.abortTransaction(broker);
    } finally {
      ojbHelper.closeBroker(broker);
    }
    return msg;
  }

  public Msgthread saveThread(Msgthread msg) throws Exception {
    PersistenceBroker broker = ojbHelper.getBroker();
    try {
      ojbHelper.beginTransaction(broker);
      broker.store(msg);
      ojbHelper.commitTransaction(broker);
    } catch (Exception e) {
      log.error("Error createmsg()", e);
      ojbHelper.abortTransaction(broker);
    } finally {
      ojbHelper.closeBroker(broker);
    }
    return msg;
  }