| NewPersistenceManager.java |
/*
* JBossMQ, the OpenSource JMS implementation
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.mq.pm.none;
import javax.jms.JMSException;
import org.jboss.mq.SpyMessage;
/**
* A persistence manager and cache store that does not persistence.
* This implements the optimized Topic persistence manager
*
* @author Adrian Brock (adrian@jboss.org)
*
* @version $Revision: 1.2 $
*/
public class NewPersistenceManager
extends PersistenceManager
implements org.jboss.mq.pm.NewPersistenceManager
{
// Constants --------------------------------------------------------------------
// Attributes -------------------------------------------------------------------
// Constructors -----------------------------------------------------------------
// Public -----------------------------------------------------------------------
// NewPersistenceManager implementation -----------------------------------------
public void addMessage(SpyMessage message) throws JMSException
{
if (delegate != null)
((org.jboss.mq.pm.NewPersistenceManager) delegate).addMessage(message);
}
// ServerMBeanSupport overrides -------------------------------------------------
protected void startService() throws Exception
{
super.startService();
if (delegate != null && (delegate instanceof org.jboss.mq.pm.NewPersistenceManager) == false)
throw new UnsupportedOperationException("The delegate persistence manager must be a NewPersistenceManager");
}
// Protected --------------------------------------------------------------------
// Inner Classes ----------------------------------------------------------------
}
| NewPersistenceManager.java |