public class ServiceDispatcher.QueuingService
extends java.lang.Object
Constructor and Description |
---|
ServiceDispatcher.QueuingService(java.lang.String serviceName,
java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel> queue) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
cancel()
Cancel the service as part of the registration being canceled.
|
(package private) void |
requestDispatch(java.nio.channels.SocketChannel channel)
Informs the service of a new request.
|
(package private) java.nio.channels.SocketChannel |
take() |
ServiceDispatcher.QueuingService(java.lang.String serviceName, java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel> queue)
java.nio.channels.SocketChannel take() throws java.lang.InterruptedException
java.lang.InterruptedException
void requestDispatch(java.nio.channels.SocketChannel channel)
channel
- the channel on which the request was madevoid cancel()
Copyright (c) 2004-2012 Oracle. All rights reserved.