User: hiram
Date: 00/12/29 12:18:38
Modified: src/java/org/spydermq SpyXATopicConnectionFactory.java
SpyXAQueueConnectionFactory.java
SpyTopicConnectionFactory.java SpyTopic.java
SpyQueueConnectionFactory.java SpyQueue.java
SpyDestination.java
Log:
Feature Add: JMS Spec stated that the managed objects needed to implement
javax.naming.Refrenceable.
Revision Changes Path
1.3 +15 -2 spyderMQ/src/java/org/spydermq/SpyXATopicConnectionFactory.java
Index: SpyXATopicConnectionFactory.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyXATopicConnectionFactory.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- SpyXATopicConnectionFactory.java 2000/12/26 04:15:51 1.2
+++ SpyXATopicConnectionFactory.java 2000/12/29 20:18:37 1.3
@@ -11,6 +11,9 @@
import javax.jms.XATopicConnectionFactory;
import javax.jms.XATopicConnection;
import javax.jms.JMSException;
+import javax.naming.StringRefAddr;
+import javax.naming.Reference;
+import javax.naming.Referenceable;
import org.spydermq.Log;
import org.spydermq.distributed.interfaces.DistributedJMSServer;
@@ -19,16 +22,15 @@
import java.io.Serializable;
import java.util.Properties;
-
/**
* This class implements javax.jms.XATopicConnectionFactory
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class SpyXATopicConnectionFactory
- implements XATopicConnectionFactory, Serializable
+ implements XATopicConnectionFactory, Serializable, Referenceable
{
//////////////////////////////////////////////////////////////////
// Attributes
@@ -79,6 +81,17 @@
failureHandler(e,"createTopicConnection has failed !");
return null;
}
+ }
+
+ /**
+ * getReference method - to implement javax.naming.Refrenceable
+ */
+ public Reference getReference() throws javax.naming.NamingException {
+
+ return new Reference(
+ "org.spydermq.SpyXATopicConnectionFactory",
+ new org.spydermq.referenceable.ObjectRefAddr("DCF", factory),
+
"org.spydermq.referenceable.SpyConnectionFactoryObjectFactory", null);
}
//////////////////////////////////////////////////////////////////
1.3 +15 -1 spyderMQ/src/java/org/spydermq/SpyXAQueueConnectionFactory.java
Index: SpyXAQueueConnectionFactory.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyXAQueueConnectionFactory.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- SpyXAQueueConnectionFactory.java 2000/12/26 04:15:51 1.2
+++ SpyXAQueueConnectionFactory.java 2000/12/29 20:18:37 1.3
@@ -10,6 +10,9 @@
import javax.jms.XAQueueConnection;
import javax.jms.XAQueueConnectionFactory;
import javax.jms.JMSException;
+import javax.naming.StringRefAddr;
+import javax.naming.Reference;
+import javax.naming.Referenceable;
import org.spydermq.Log;
import org.spydermq.distributed.interfaces.DistributedJMSServer;
@@ -23,10 +26,10 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class SpyXAQueueConnectionFactory
- implements XAQueueConnectionFactory, Serializable
+ implements XAQueueConnectionFactory, Serializable, Referenceable
{
// Attributes ----------------------------------------------------
@@ -86,5 +89,16 @@
failureHandler(e,"createQueueConnection has failed !");
return null;
}
+ }
+
+ /**
+ * getReference method - to implement javax.naming.Refrenceable
+ */
+ public Reference getReference() throws javax.naming.NamingException {
+
+ return new Reference(
+ "org.spydermq.SpyXAQueueConnectionFactory",
+ new org.spydermq.referenceable.ObjectRefAddr("DCF", factory),
+
"org.spydermq.referenceable.SpyConnectionFactoryObjectFactory", null);
}
}
1.3 +15 -2 spyderMQ/src/java/org/spydermq/SpyTopicConnectionFactory.java
Index: SpyTopicConnectionFactory.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyTopicConnectionFactory.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- SpyTopicConnectionFactory.java 2000/12/26 04:15:50 1.2
+++ SpyTopicConnectionFactory.java 2000/12/29 20:18:37 1.3
@@ -9,6 +9,9 @@
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.JMSException;
+import javax.naming.StringRefAddr;
+import javax.naming.Reference;
+import javax.naming.Referenceable;
import org.spydermq.Log;
import org.spydermq.distributed.interfaces.DistributedJMSServer;
@@ -23,10 +26,10 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class SpyTopicConnectionFactory
- implements TopicConnectionFactory, Serializable
+ implements TopicConnectionFactory, Serializable, Referenceable
{
// Attributes ----------------------------------------------------
@@ -65,6 +68,17 @@
return null;
}
}
+
+ /**
+ * getReference method - to implement javax.naming.Refrenceable
+ */
+ public Reference getReference() throws javax.naming.NamingException {
+
+ return new Reference(
+ "org.spydermq.SpyTopicConnectionFactory",
+ new org.spydermq.referenceable.ObjectRefAddr("DCF", factory),
+
"org.spydermq.referenceable.SpyConnectionFactoryObjectFactory", null);
+ }
// Private ------------------------------------------------------
@@ -73,5 +87,4 @@
Log.error(e);
throw new JMSException(reason);
}
-
}
1.5 +15 -2 spyderMQ/src/java/org/spydermq/SpyTopic.java
Index: SpyTopic.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyTopic.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- SpyTopic.java 2000/12/12 21:01:38 1.4
+++ SpyTopic.java 2000/12/29 20:18:37 1.5
@@ -8,6 +8,10 @@
import javax.jms.Topic;
import javax.jms.JMSException;
+import javax.naming.Referenceable;
+import javax.naming.StringRefAddr;
+import javax.naming.Reference;
+
import java.io.Serializable;
/**
@@ -16,11 +20,11 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public class SpyTopic
extends SpyDestination
- implements Topic, Serializable
+ implements Topic, Serializable, Referenceable
{
// Constructor ---------------------------------------------------
@@ -51,4 +55,13 @@
return ((SpyDestination)obj).name.equals(name);
}
+ /**
+ * getReference method - to implement javax.naming.Refrenceable
+ */
+ public Reference getReference() throws javax.naming.NamingException {
+ return new Reference(
+ "org.spydermq.SpyTopic",
+ new StringRefAddr("name", name),
+ "org.spydermq.referenceable.SpyDestinationObjectFactory",
null);
+ }
}
1.3 +15 -1 spyderMQ/src/java/org/spydermq/SpyQueueConnectionFactory.java
Index: SpyQueueConnectionFactory.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyQueueConnectionFactory.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- SpyQueueConnectionFactory.java 2000/12/26 04:15:50 1.2
+++ SpyQueueConnectionFactory.java 2000/12/29 20:18:37 1.3
@@ -9,6 +9,9 @@
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.JMSException;
+import javax.naming.StringRefAddr;
+import javax.naming.Reference;
+import javax.naming.Referenceable;
import org.spydermq.Log;
import org.spydermq.distributed.interfaces.DistributedJMSServer;
@@ -23,10 +26,10 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class SpyQueueConnectionFactory
- implements QueueConnectionFactory, Serializable
+ implements QueueConnectionFactory, Serializable, Referenceable
{
// Attributes ----------------------------------------------------
@@ -64,6 +67,17 @@
failureHandler(e,"createQueueConnection has failed !");
return null;
}
+ }
+
+ /**
+ * getReference method - to implement javax.naming.Refrenceable
+ */
+ public Reference getReference() throws javax.naming.NamingException {
+
+ return new Reference(
+ "org.spydermq.SpyQueueConnectionFactory",
+ new org.spydermq.referenceable.ObjectRefAddr("DCF", factory),
+
"org.spydermq.referenceable.SpyConnectionFactoryObjectFactory", null);
}
//private
1.5 +16 -3 spyderMQ/src/java/org/spydermq/SpyQueue.java
Index: SpyQueue.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyQueue.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- SpyQueue.java 2000/12/12 20:59:51 1.4
+++ SpyQueue.java 2000/12/29 20:18:37 1.5
@@ -8,6 +8,10 @@
import javax.jms.Queue;
import javax.jms.JMSException;
+import javax.naming.Referenceable;
+import javax.naming.StringRefAddr;
+import javax.naming.Reference;
+
import java.io.Serializable;
/**
@@ -16,13 +20,12 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public class SpyQueue
extends SpyDestination
- implements Queue, Serializable
+ implements Queue, Serializable, Referenceable
{
-
// Constructor ---------------------------------------------------
public SpyQueue(String queueName)
@@ -53,4 +56,14 @@
return ((SpyQueue)obj).name.equals(name);
}
+ /**
+ * getReference method - to implement javax.naming.Refrenceable
+ */
+ public Reference getReference() throws javax.naming.NamingException {
+
+ return new Reference(
+ "org.spydermq.SpyQueue",
+ new StringRefAddr("name", name),
+ "org.spydermq.referenceable.SpyDestinationObjectFactory",
null);
+ }
}
1.4 +3 -2 spyderMQ/src/java/org/spydermq/SpyDestination.java
Index: SpyDestination.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyDestination.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- SpyDestination.java 2000/12/12 05:58:58 1.3
+++ SpyDestination.java 2000/12/29 20:18:37 1.4
@@ -7,16 +7,17 @@
package org.spydermq;
import javax.jms.Destination;
-import java.io.Serializable;
import javax.naming.Referenceable;
+import java.io.Serializable;
+
/**
* This class implements javax.jms.Destination
*
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class SpyDestination
implements Destination, Serializable
