Package org.apache.cassandra.transport

Class SimpleClient.SimpleFlusher

java.lang.Object

org.apache.cassandra.transport.SimpleClient.SimpleFlusher

Enclosing class:

SimpleClient

public static class SimpleClient.SimpleFlusher
extends Object

Method Summary

Modifier and Type	Method	Description
void	enqueue(Envelope message)
void	maybeWrite(io.netty.channel.ChannelHandlerContext ctx, io.netty.util.concurrent.Promise<Void> promise)
void	releaseAll()
void	schedule(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class java.lang.Object

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

Method Details

enqueue

public void enqueue(Envelope message)

releaseAll

public void releaseAll()

schedule

public void schedule(io.netty.channel.ChannelHandlerContext ctx)

maybeWrite

public void maybeWrite(io.netty.channel.ChannelHandlerContext ctx,
 io.netty.util.concurrent.Promise<Void> promise)