com.hazelcast.internal.networking.spinning

Class SpinningChannelWriter

java.lang.Object

com.hazelcast.internal.networking.spinning.AbstractHandler

com.hazelcast.internal.networking.spinning.SpinningChannelWriter

public class SpinningChannelWriter
extends AbstractHandler

Field Summary

Fields

Modifier and Type	Field and Description
Queue<OutboundFrame>	urgentWriteQueue
Queue<OutboundFrame>	writeQueue

Fields inherited from class com.hazelcast.internal.networking.spinning.AbstractHandler

channel, logger

Constructor Summary

Constructors

Constructor and Description
SpinningChannelWriter(Channel channel, ILogger logger, ChannelErrorHandler errorHandler, ChannelInitializer initializer)

Method Summary

Modifier and Type	Method and Description
long	bytesPending()
void	close()
long	lastWriteTimeMillis()
long	priorityBytesPending()
int	totalFramesPending()
void	write()
void	write(OutboundFrame frame)

Methods inherited from class com.hazelcast.internal.networking.spinning.AbstractHandler

getChannel, onFailure

Methods inherited from class java.lang.Object

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

Field Detail

writeQueue

public final Queue<OutboundFrame> writeQueue

urgentWriteQueue

public final Queue<OutboundFrame> urgentWriteQueue

Constructor Detail

SpinningChannelWriter

public SpinningChannelWriter(Channel channel,
                             ILogger logger,
                             ChannelErrorHandler errorHandler,
                             ChannelInitializer initializer)

Method Detail

write

public void write(OutboundFrame frame)

bytesPending

public long bytesPending()

priorityBytesPending

public long priorityBytesPending()

totalFramesPending

public int totalFramesPending()

lastWriteTimeMillis

public long lastWriteTimeMillis()

close

public void close()

write

public void write()
           throws Exception

Throws:

Exception