com.sleepycat.je.rep.utilint

Class ServiceDispatcher.QueuingService

java.lang.Object

com.sleepycat.je.rep.utilint.ServiceDispatcher.QueuingService

Direct Known Subclasses:

ServiceDispatcher.LazyQueuingService

Enclosing class:

ServiceDispatcher

public class ServiceDispatcher.QueuingService
extends java.lang.Object

A service where requests are simply added to the supplied queue. It's the responsibility of the service creator to drain the queue. This service is used when the service carries out a long-running dialog with the service requester. For example, a Feeder service.

Constructor Summary

Constructors

Constructor and Description
ServiceDispatcher.QueuingService(java.lang.String serviceName, java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel> queue)

Method Summary

Methods

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServiceDispatcher.QueuingService

ServiceDispatcher.QueuingService(java.lang.String serviceName,
                                java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel> queue)

Method Detail

take

java.nio.channels.SocketChannel take()
                               throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

requestDispatch

void requestDispatch(java.nio.channels.SocketChannel channel)

Informs the service of a new request. The implementation of the method must not block.

Parameters:

channel - the channel on which the request was made

cancel

void cancel()

Cancel the service as part of the registration being canceled.