User: pkendall
Date: 01/08/09 01:09:49
Modified: src/main/org/jbossmq/server BasicQueue.java
Log:
no message
Revision Changes Path
1.11 +3 -3 jbossmq/src/main/org/jbossmq/server/BasicQueue.java
Index: BasicQueue.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/BasicQueue.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- BasicQueue.java 2001/08/09 01:18:28 1.10
+++ BasicQueue.java 2001/08/09 08:09:49 1.11
@@ -33,7 +33,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author David Maplesden ([EMAIL PROTECTED])
*
- * @version $Revision: 1.10 $
+ * @version $Revision: 1.11 $
*/
//abstract public class BasicQueue implements Runnable {
public class BasicQueue {
@@ -41,7 +41,7 @@
SortedSet messages = new TreeSet();
//The JMSServer object
JMSServer server;
- // The subscribers waiting for messages
+ // The subscribers waiting for messages
HashSet receivers = new HashSet();
//List of messages that should be acked or else returned to thier
//owning exclusive queues.
@@ -197,7 +197,7 @@
r.message = message;
r.subscriptionId = new Integer(sub.subscriptionId);
- sub.clientConsumer.queueMessageForSending(r);
+ ((ClientConsumer)sub.clientConsumer).queueMessageForSending(r);
}
public void addReceiver(Subscription sub){
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
