org.apache.avro.ipc

Class NettyTransceiver.WriteFutureListener

java.lang.Object

org.apache.avro.ipc.NettyTransceiver.WriteFutureListener

All Implemented Interfaces:

EventListener, org.jboss.netty.channel.ChannelFutureListener

Enclosing class:

NettyTransceiver

protected class NettyTransceiver.WriteFutureListener
extends Object
implements org.jboss.netty.channel.ChannelFutureListener

A ChannelFutureListener for channel write operations that notifies a Callback if an error occurs while writing to the channel.

Field Summary

Fields

Modifier and Type	Field and Description
protected Callback<List<ByteBuffer>>	callback

Fields inherited from interface org.jboss.netty.channel.ChannelFutureListener

CLOSE, CLOSE_ON_FAILURE

Constructor Summary

Constructors

Constructor and Description
NettyTransceiver.WriteFutureListener(Callback<List<ByteBuffer>> callback) Creates a WriteFutureListener that notifies the given callback if an error occurs writing data to the channel.

Method Summary

Methods

Modifier and Type	Method and Description
void	operationComplete(org.jboss.netty.channel.ChannelFuture future)

Methods inherited from class java.lang.Object

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

Field Detail

callback

protected final Callback<List<ByteBuffer>> callback

Constructor Detail

NettyTransceiver.WriteFutureListener

public NettyTransceiver.WriteFutureListener(Callback<List<ByteBuffer>> callback)

Creates a WriteFutureListener that notifies the given callback if an error occurs writing data to the channel.

Parameters:

callback - the callback to notify, or null to skip notification.

Method Detail

operationComplete

public void operationComplete(org.jboss.netty.channel.ChannelFuture future)
                       throws Exception

Specified by:

operationComplete in interface org.jboss.netty.channel.ChannelFutureListener

Throws:

Exception