Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse code

Merge branch 'master' of github.com:fusesource/hawtdispatch

  • Loading branch information...
commit 649d28f8c5371f6d136d327813caf03df81e4186 2 parents cba3c89 + a14ae61
Hiram Chirino authored February 13, 2012
4  hawtdispatch-transport/src/main/java/org/fusesource/hawtdispatch/transport/TcpTransport.java
@@ -388,6 +388,10 @@ public DispatchQueue getDispatchQueue() {
388 388
 
389 389
     public void setDispatchQueue(DispatchQueue queue) {
390 390
         this.dispatchQueue = queue;
  391
+        if(readSource!=null) readSource.setTargetQueue(queue);
  392
+        if(writeSource!=null) writeSource.setTargetQueue(queue);
  393
+        if(drainOutboundSource!=null) drainOutboundSource.setTargetQueue(queue);
  394
+        if(yieldSource!=null) yieldSource.setTargetQueue(queue);
391 395
     }
392 396
 
393 397
     public void _start(Runnable onCompleted) {
1  hawtdispatch/src/main/java/org/fusesource/hawtdispatch/internal/AbstractDispatchObject.java
@@ -29,6 +29,7 @@
29 29
     protected volatile HawtDispatchQueue targetQueue;
30 30
 
31 31
     public void setTargetQueue(DispatchQueue next) {
  32
+        assert next!=this : "You cannot not set the target queue to this";
32 33
 
33 34
         if( next!=targetQueue ) {
34 35
             // Don't see why someone would concurrently try to set the target..

0 notes on commit 649d28f

Please sign in to comment.
Something went wrong with that request. Please try again.