1 22 package org.jboss.mq.pm.none; 23 24 import javax.jms.JMSException ; 25 26 import org.jboss.mq.SpyMessage; 27 28 36 public class NewPersistenceManager 37 extends PersistenceManager 38 implements org.jboss.mq.pm.NewPersistenceManager 39 { 40 42 44 46 48 50 public void addMessage(SpyMessage message) throws JMSException 51 { 52 if (delegate != null) 53 ((org.jboss.mq.pm.NewPersistenceManager) delegate).addMessage(message); 54 } 55 56 58 protected void startService() throws Exception 59 { 60 super.startService(); 61 if (delegate != null && (delegate instanceof org.jboss.mq.pm.NewPersistenceManager) == false) 62 throw new UnsupportedOperationException ("The delegate persistence manager must be a NewPersistenceManager"); 63 } 64 65 67 } 69 | Popular Tags |