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
