libreccm-legacy/ccm-core/src/com/redhat/persistence/FlushException.java

74 lines
2.4 KiB
Java
Executable File

/*
* Copyright (C) 2003-2004 Red Hat Inc. All Rights Reserved.
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
*/
package com.redhat.persistence;
import java.util.Collection;
import java.util.Iterator;
/**
* FlushException. It has an object for which a flush was attempted. If the
* object is null, the associated flush was for all events. The constructors
* take a collection of property datas which are responsible for the inability
* to flush.
*
* @author Rafael H. Schloming <rhs@mit.edu>
* @version $Id: FlushException.java 287 2005-02-22 00:29:02Z sskracic $
**/
public class FlushException extends ProtoException {
private final Object m_obj;
private static String msg(Object obj, Collection pds) {
StringBuffer sb = new StringBuffer();
if (obj == null) {
sb.append("Unable to send all events to database");
} else {
sb.append("Unable to send all events to database for object ");
sb.append(obj);
}
sb.append(" because these required properties are null:");
for (Iterator it = pds.iterator(); it.hasNext(); ) {
PropertyData pd = (PropertyData) it.next();
sb.append("\n ");
sb.append(pd.getObjectData().getObject() + "."
+ pd.getProperty().getName());
}
return sb.toString();
}
FlushException(Object obj, Collection pds) {
super(msg(obj, pds), false);
m_obj = obj;
if (Session.LOG.isInfoEnabled()) {
Session.LOG.info("Unable to send all events to database.", this);
}
}
FlushException(Collection pds) {
this(null, pds);
}
public Object getObject() { return m_obj; }
}