Package org.apache.cassandra.transport

Class Dispatcher

java.lang.Object

org.apache.cassandra.transport.Dispatcher

public class Dispatcher
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Dispatcher.RequestProcessor	It is important to keep this class an instance of DebuggableTask, either runnable or callable since this is the only way we can keep it not wrapped into a callable on SEPExecutor submission path.
static class	Dispatcher.RequestTime

Constructor Summary

Constructors

Constructor	Description
Dispatcher(boolean useLegacyFlusher)

Method Summary

Modifier and Type	Method	Description
void	dispatch(io.netty.channel.Channel channel, Message.Request request, org.apache.cassandra.transport.Dispatcher.FlushItemConverter forFlusher, ClientResourceLimits.Overload backpressure)
boolean	hasQueueCapacity()	Checks if the item in the head of the queue has spent more than allowed time in the queue.
boolean	isDone()
static void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

Dispatcher

public Dispatcher(boolean useLegacyFlusher)

Method Details

dispatch

public void dispatch(io.netty.channel.Channel channel,
 Message.Request request,
 org.apache.cassandra.transport.Dispatcher.FlushItemConverter forFlusher,
 ClientResourceLimits.Overload backpressure)

hasQueueCapacity

public boolean hasQueueCapacity()

Checks if the item in the head of the queue has spent more than allowed time in the queue.

isDone

public boolean isDone()

shutdown

public static void shutdown()