1 22 package org.jboss.mq.kernel; 23 24 import org.jboss.mq.server.*; 25 import org.jboss.mq.pm.PersistenceManager; 26 import org.jboss.mq.sm.StateManager; 27 28 34 public class DestinationManager extends org.jboss.mq.server.jmx.DestinationManager 35 { 36 protected PersistenceManager persistenceManagerInstance; 37 protected StateManager stateManagerInstance; 38 protected org.jboss.mq.server.MessageCache messageCacheInstance; 39 40 public void create() throws Exception 41 { 42 jmsServer = new JMSDestinationManager(tempParameters); 43 } 44 45 public void start() throws Exception 46 { 47 jmsServer.setPersistenceManager(persistenceManagerInstance); 48 jmsServer.setMessageCache(messageCacheInstance); 49 jmsServer.setStateManager(stateManagerInstance); 50 51 jmsServer.startServer(); 52 } 53 54 public void stop() 55 { 56 jmsServer.stopServer(); 57 } 58 59 public void destroy() 60 { 61 jmsServer = null; 62 } 63 64 public void setPersistenceManagerInstance(PersistenceManager persistenceManagerInstance) 65 { 66 this.persistenceManagerInstance = persistenceManagerInstance; 67 } 68 69 public void setStateManagerInstance(StateManager stateManagerInstance) 70 { 71 this.stateManagerInstance = stateManagerInstance; 72 } 73 74 public void setMessageCacheInstance(org.jboss.mq.server.MessageCache messageCacheInstance) 75 { 76 this.messageCacheInstance = messageCacheInstance; 77 } 78 } 79 | Popular Tags |