User: pkendall
Date: 01/07/31 20:09:25
Modified: src/main/org/jbossmq/server ClientConsumer.java
Log:
Fix start/stop connection
Revision Changes Path
1.15 +17 -2 jbossmq/src/main/org/jbossmq/server/ClientConsumer.java
Index: ClientConsumer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/ClientConsumer.java,v
retrieving revision 1.14
retrieving revision 1.15
diff -u -r1.14 -r1.15
--- ClientConsumer.java 2001/07/30 09:23:23 1.14
+++ ClientConsumer.java 2001/08/01 03:09:25 1.15
@@ -31,7 +31,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.14 $
+ * @version $Revision: 1.15 $
*/
public class ClientConsumer implements Runnable {
@@ -109,6 +109,9 @@
{
cat.debug("Queueing outbound message: "+message);
+ if( !enabled )
+ return;
+
LinkedList l = (LinkedList)destinationSubscriptions.get(
message.getJMSDestination() );
if( l == null )
throw new JMSException("No subscription found for that
destination.");
@@ -238,7 +241,7 @@
if( queue == null )
throw new JMSException("The subscription's destination does
not exist");
- if( req.subscription.actsLikeAQueue ) {
+ if( enabled && req.subscription.actsLikeAQueue ) {
SpyMessage message = req.dest.receiveNoWait(req.subscription);
if( message != null ) {
@@ -340,6 +343,9 @@
cat.debug(""+this+"->scanExclusiveQueue(queue="+queue+")");
+ if( !enabled )
+ return false;
+
Iterator i = queue.messages.iterator();
while( i.hasNext() ) {
@@ -391,6 +397,15 @@
public void setEnabled(boolean enabled) {
cat.debug(""+this+"->setEnabled(enabled="+enabled+")");
this.enabled = enabled;
+ if(enabled){
+ // queues might be waiting for messages.
+ for(Iterator it =
destinationSubscriptions.keySet().iterator();it.hasNext();){
+ SpyDestination destination = (SpyDestination)
it.next();
+ JMSDestination dest =
server.getJMSDestination(destination);
+ if(dest != null)
+ dest.notifyMessageAvailable();
+ }
+ }
}
public String toString() {
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
