User: hiram
Date: 00/12/26 11:09:41
Modified: src/java/org/spydermq SpyTopicConnection.java
Log:
Add Topic support for the ASF
Revision Changes Path
1.3 +2 -3 spyderMQ/src/java/org/spydermq/SpyTopicConnection.java
Index: SpyTopicConnection.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyTopicConnection.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- SpyTopicConnection.java 2000/12/12 05:58:56 1.2
+++ SpyTopicConnection.java 2000/12/26 19:09:41 1.3
@@ -24,7 +24,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class SpyTopicConnection
extends SpyConnection
@@ -67,8 +67,7 @@
if (closed) throw new IllegalStateException("The connection is
closed");
if (distributedConnection==null) createReceiver();
- //Not impelemted yet
- return null;
+ return new SpyConnectionConsumer(this, topic, messageSelector,
sessionPool, maxMessages);
}
public ConnectionConsumer createDurableConnectionConsumer(Topic topic,
