public class FileUploadChannelHandler
extends io.netty.channel.ChannelInboundHandlerAdapter
Modifier and Type | Field and Description |
---|---|
protected com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> |
asyncBroker |
protected io.netty.util.concurrent.EventExecutor |
eventExecutor |
protected FileChannel |
fileChannel |
protected FileResponse |
fileResponse |
protected Path |
tempFilePath |
Constructor and Description |
---|
FileUploadChannelHandler(com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> asyncBroker,
FileResponse fileResponse,
io.netty.util.concurrent.EventExecutor eventExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
channelRead(io.netty.channel.ChannelHandlerContext channelHandlerContext,
Object object) |
void |
exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
Throwable throwable) |
protected void |
finish() |
protected boolean |
receive(io.netty.buffer.ByteBuf byteBuf) |
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
protected final com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> asyncBroker
protected final io.netty.util.concurrent.EventExecutor eventExecutor
protected final FileChannel fileChannel
protected final FileResponse fileResponse
protected final Path tempFilePath
public FileUploadChannelHandler(com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> asyncBroker, FileResponse fileResponse, io.netty.util.concurrent.EventExecutor eventExecutor) throws IOException
IOException
public void channelRead(io.netty.channel.ChannelHandlerContext channelHandlerContext, Object object) throws IOException
channelRead
in interface io.netty.channel.ChannelInboundHandler
channelRead
in class io.netty.channel.ChannelInboundHandlerAdapter
IOException
public void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext, Throwable throwable) throws IOException
exceptionCaught
in interface io.netty.channel.ChannelHandler
exceptionCaught
in interface io.netty.channel.ChannelInboundHandler
exceptionCaught
in class io.netty.channel.ChannelInboundHandlerAdapter
IOException
protected void finish() throws IOException
IOException
protected boolean receive(io.netty.buffer.ByteBuf byteBuf) throws IOException
IOException