User: lqd Date: 02/02/01 20:02:24 Modified: src/main/org/jboss/mq/server JMSServer.java JMSTopic.java StateManager.java TopicManager.java Log: Fix typo. this just ate 30mins of my time ... realizing a missing "s" in the class name ... argh! Revision Changes Path 1.14 +3 -3 jbossmq/src/main/org/jboss/mq/server/JMSServer.java Index: JMSServer.java =================================================================== RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/JMSServer.java,v retrieving revision 1.13 retrieving revision 1.14 diff -u -r1.13 -r1.14 --- JMSServer.java 2002/02/02 03:54:21 1.13 +++ JMSServer.java 2002/02/02 04:02:24 1.14 @@ -26,7 +26,7 @@ import org.jboss.mq.AcknowledgementRequest; import org.jboss.mq.ConnectionToken; -import org.jboss.mq.DurableSubcriptionID; +import org.jboss.mq.DurableSubscriptionID; import org.jboss.mq.SpyDestination; import org.jboss.mq.SpyMessage; import org.jboss.mq.SpyQueue; @@ -48,7 +48,7 @@ * @author Norbert Lataille ([EMAIL PROTECTED]) * @author Hiram Chirino ([EMAIL PROTECTED]) * @author David Maplesden ([EMAIL PROTECTED]) - * @version $Revision: 1.13 $ + * @version $Revision: 1.14 $ */ public class JMSServer { @@ -647,7 +647,7 @@ * @param id Description of Parameter * @exception JMSException Description of Exception */ - public void destroySubscription(DurableSubcriptionID id) throws JMSException + public void destroySubscription(DurableSubscriptionID id) throws JMSException { getStateManager().setDurableSubscription(this, id, null); } 1.10 +9 -9 jbossmq/src/main/org/jboss/mq/server/JMSTopic.java Index: JMSTopic.java =================================================================== RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/JMSTopic.java,v retrieving revision 1.9 retrieving revision 1.10 diff -u -r1.9 -r1.10 --- JMSTopic.java 2002/02/02 03:54:21 1.9 +++ JMSTopic.java 2002/02/02 04:02:24 1.10 @@ -18,7 +18,7 @@ import javax.jms.Destination; import javax.jms.JMSException; -import org.jboss.mq.DurableSubcriptionID; +import org.jboss.mq.DurableSubscriptionID; import org.jboss.mq.SpyDestination; import org.jboss.mq.SpyMessage; import org.jboss.mq.SpyTopic; @@ -32,7 +32,7 @@ * @author Hiram Chirino ([EMAIL PROTECTED]) * @author David Maplesden ([EMAIL PROTECTED]) * @created August 16, 2001 - * @version $Revision: 1.9 $ + * @version $Revision: 1.10 $ */ public class JMSTopic extends JMSDestination { @@ -62,7 +62,7 @@ public void addSubscriber(Subscription sub) throws JMSException { SpyTopic topic = (SpyTopic) sub.destination; - DurableSubcriptionID id = topic.getDurableSubscriptionID(); + DurableSubscriptionID id = topic.getDurableSubscriptionID(); if (id == null) { BasicQueue q = new BasicQueue(server); synchronized (tempQueues) { @@ -84,7 +84,7 @@ public void removeSubscriber(Subscription sub) throws JMSException { BasicQueue queue = null; SpyTopic topic = (SpyTopic) sub.destination; - DurableSubcriptionID id = topic.getDurableSubscriptionID(); + DurableSubscriptionID id = topic.getDurableSubscriptionID(); if (id == null) { synchronized (tempQueues) { queue = (BasicQueue) tempQueues.get(sub); @@ -128,7 +128,7 @@ } } //called by state manager when a durable sub is created - public void createDurableSubscription(DurableSubcriptionID id) throws JMSException { + public void createDurableSubscription(DurableSubscriptionID id) throws JMSException { if (temporaryDestination != null) { throw new JMSException("Not a valid operation on a temporary topic"); } @@ -143,7 +143,7 @@ } //called by state manager when a durable sub is deleted - public void destroyDurableSubscription(DurableSubcriptionID id) throws JMSException { + public void destroyDurableSubscription(DurableSubscriptionID id) throws JMSException { BasicQueue queue; synchronized (durQueues) { queue = (BasicQueue) durQueues.remove(id); @@ -173,7 +173,7 @@ synchronized (durQueues) { Iterator iter = durQueues.keySet().iterator(); while (iter.hasNext()) { - DurableSubcriptionID id = (DurableSubcriptionID) iter.next(); + DurableSubscriptionID id = (DurableSubscriptionID) iter.next(); PersistentQueue q = (PersistentQueue) durQueues.get(id); SpyMessage clone = message.myClone(); clone.header.durableSubscriberID = id; @@ -201,7 +201,7 @@ } // Package protected --------------------------------------------- - PersistentQueue getDurableSubscription(DurableSubcriptionID id) { + PersistentQueue getDurableSubscription(DurableSubscriptionID id) { synchronized (durQueues) { return (PersistentQueue) durQueues.get(id); } @@ -209,7 +209,7 @@ private BasicQueue getQueue(Subscription sub) { SpyTopic topic = (SpyTopic) sub.destination; - DurableSubcriptionID id = topic.getDurableSubscriptionID(); + DurableSubscriptionID id = topic.getDurableSubscriptionID(); if (id != null) { return getDurableSubscription(id); } else { 1.13 +5 -5 jbossmq/src/main/org/jboss/mq/server/StateManager.java Index: StateManager.java =================================================================== RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/StateManager.java,v retrieving revision 1.12 retrieving revision 1.13 diff -u -r1.12 -r1.13 --- StateManager.java 2002/02/02 03:54:21 1.12 +++ StateManager.java 2002/02/02 04:02:24 1.13 @@ -22,7 +22,7 @@ import javax.jms.JMSSecurityException; import javax.naming.InitialContext; -import org.jboss.mq.DurableSubcriptionID; +import org.jboss.mq.DurableSubscriptionID; import org.jboss.mq.SpyJMSException; import org.jboss.mq.SpyTopic; import org.jboss.mq.server.JMSServer; @@ -35,7 +35,7 @@ * * @author Norbert Lataille ([EMAIL PROTECTED]) * @author <a href="[EMAIL PROTECTED]">Hiram Chirino</a> - * @version $Revision: 1.12 $ + * @version $Revision: 1.13 $ */ public class StateManager extends ServiceMBeanSupport implements StateManagerMBean { @@ -80,7 +80,7 @@ * @param topic The new DurableSubscription value * @exception JMSException Description of Exception */ - public void setDurableSubscription(JMSServer server, DurableSubcriptionID sub, SpyTopic topic) throws JMSException + public void setDurableSubscription(JMSServer server, DurableSubscriptionID sub, SpyTopic topic) throws JMSException { boolean debug = log.isDebugEnabled(); if (debug) @@ -367,7 +367,7 @@ String topicName = element.getField("TopicName"); if (topic.getName().equals(topicName)) { - durableSubs.add(new DurableSubcriptionID(clientId, name)); + durableSubs.add(new DurableSubscriptionID(clientId, name)); } // end of if () } @@ -414,7 +414,7 @@ } else { - dest.createDurableSubscription(new DurableSubcriptionID(clientId, name)); + dest.createDurableSubscription(new DurableSubscriptionID(clientId, name)); } } 1.11 +3 -3 jbossmq/src/main/org/jboss/mq/server/TopicManager.java Index: TopicManager.java =================================================================== RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/TopicManager.java,v retrieving revision 1.10 retrieving revision 1.11 diff -u -r1.10 -r1.11 --- TopicManager.java 2002/02/02 03:54:21 1.10 +++ TopicManager.java 2002/02/02 04:02:24 1.11 @@ -24,7 +24,7 @@ import org.jboss.system.ServiceMBeanSupport; -import org.jboss.mq.DurableSubcriptionID;//Typo!!! +import org.jboss.mq.DurableSubscriptionID; import org.jboss.mq.SpyTopic; import org.jboss.naming.Util; @@ -36,7 +36,7 @@ * * @author Norbert Lataille ([EMAIL PROTECTED]) * @author <a href="[EMAIL PROTECTED]">Hiram Chirino</a> -* @version $Revision: 1.10 $ +* @version $Revision: 1.11 $ */ public class TopicManager extends ServiceMBeanSupport @@ -118,7 +118,7 @@ Collection durableSubs = sm.getDurableSubscriptionIdsForTopic(topic); for (Iterator i = durableSubs.iterator(); i.hasNext();) { - destination.createDurableSubscription((DurableSubcriptionID)i.next()); + destination.createDurableSubscription((DurableSubscriptionID)i.next()); } // end of for () //server.getPersistenceManager().restoreQueue(destination, topic);
_______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development