Skip to content
Browse files

Support updating the transport's dispatch queue.

  • Loading branch information...
1 parent 5321b39 commit a14ae61191962dd2283cc6c09eeb15ee0f172e3b @chirino committed Feb 5, 2012
View
4 hawtdispatch-transport/src/main/java/org/fusesource/hawtdispatch/transport/TcpTransport.java
@@ -388,6 +388,10 @@ public DispatchQueue getDispatchQueue() {
public void setDispatchQueue(DispatchQueue queue) {
this.dispatchQueue = queue;
+ if(readSource!=null) readSource.setTargetQueue(queue);
+ if(writeSource!=null) writeSource.setTargetQueue(queue);
+ if(drainOutboundSource!=null) drainOutboundSource.setTargetQueue(queue);
+ if(yieldSource!=null) yieldSource.setTargetQueue(queue);
}
public void _start(Runnable onCompleted) {

0 comments on commit a14ae61

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