org.apache.nifi.io.nio

Class DatagramChannelReader

java.lang.Object

org.apache.nifi.io.nio.AbstractChannelReader

org.apache.nifi.io.nio.DatagramChannelReader

All Implemented Interfaces:

Runnable

public final class DatagramChannelReader
extends AbstractChannelReader

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_UDP_PACKET_SIZE
private boolean	readSingleDatagram

Constructor Summary

Constructors

Constructor and Description
DatagramChannelReader(String id, SelectionKey key, BufferPool empties, StreamConsumerFactory consumerFactory, boolean readSingleDatagram)

Method Summary

Methods

Modifier and Type	Method and Description
protected int	fillBuffer(SelectionKey key, ByteBuffer buffer) Will receive UDP data from channel and won't receive anything unless the given buffer has enough space for at least one full max udp packet.

Methods inherited from class org.apache.nifi.io.nio.AbstractChannelReader

equals, getScheduledFuture, getSelectionKey, hashCode, isClosed, run, setScheduledFuture, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

MAX_UDP_PACKET_SIZE

public static final int MAX_UDP_PACKET_SIZE

See Also:

Constant Field Values

readSingleDatagram

private final boolean readSingleDatagram

Constructor Detail

DatagramChannelReader

public DatagramChannelReader(String id,
                     SelectionKey key,
                     BufferPool empties,
                     StreamConsumerFactory consumerFactory,
                     boolean readSingleDatagram)

Method Detail

fillBuffer

protected int fillBuffer(SelectionKey key,
             ByteBuffer buffer)
                  throws IOException

Will receive UDP data from channel and won't receive anything unless the given buffer has enough space for at least one full max udp packet.

Specified by:

fillBuffer in class AbstractChannelReader

Parameters:

key - selection key

buffer - to fill

Returns:

bytes read

Throws:

IOException - if error filling buffer from channel