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, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharableprotected 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
IOExceptionpublic void channelRead(io.netty.channel.ChannelHandlerContext channelHandlerContext,
Object object)
throws IOException
channelRead in interface io.netty.channel.ChannelInboundHandlerchannelRead in class io.netty.channel.ChannelInboundHandlerAdapterIOExceptionpublic void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
Throwable throwable)
throws IOException
exceptionCaught in interface io.netty.channel.ChannelHandlerexceptionCaught in interface io.netty.channel.ChannelInboundHandlerexceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapterIOExceptionprotected void finish()
throws IOException
IOExceptionprotected boolean receive(io.netty.buffer.ByteBuf byteBuf)
throws IOException
IOException