public class FileUploadChannelHandler
extends io.netty.channel.ChannelInboundHandlerAdapter
| Modifier and Type | Field and Description |
|---|---|
protected com.liferay.portal.kernel.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> |
asyncBroker |
protected io.netty.util.concurrent.EventExecutor |
eventExecutor |
protected java.nio.channels.FileChannel |
fileChannel |
protected FileResponse |
fileResponse |
protected java.nio.file.Path |
tempFilePath |
| Constructor and Description |
|---|
FileUploadChannelHandler(com.liferay.portal.kernel.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker,
FileResponse fileResponse,
io.netty.util.concurrent.EventExecutor eventExecutor) |
| Modifier and Type | Method and Description |
|---|---|
void |
channelRead(io.netty.channel.ChannelHandlerContext channelHandlerContext,
java.lang.Object object) |
void |
exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
java.lang.Throwable throwable) |
protected void |
finish() |
protected boolean |
receive(io.netty.buffer.ByteBuf byteBuf) |
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggeredhandlerAdded, handlerRemoved, isSharableprotected final com.liferay.portal.kernel.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker
protected final io.netty.util.concurrent.EventExecutor eventExecutor
protected final java.nio.channels.FileChannel fileChannel
protected final FileResponse fileResponse
protected final java.nio.file.Path tempFilePath
public FileUploadChannelHandler(com.liferay.portal.kernel.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker, FileResponse fileResponse, io.netty.util.concurrent.EventExecutor eventExecutor) throws java.io.IOException
java.io.IOExceptionpublic void channelRead(io.netty.channel.ChannelHandlerContext channelHandlerContext,
java.lang.Object object)
throws java.io.IOException
channelRead in interface io.netty.channel.ChannelInboundHandlerchannelRead in class io.netty.channel.ChannelInboundHandlerAdapterjava.io.IOExceptionpublic void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
java.lang.Throwable throwable)
throws java.io.IOException
exceptionCaught in interface io.netty.channel.ChannelHandlerexceptionCaught in interface io.netty.channel.ChannelInboundHandlerexceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapterjava.io.IOExceptionprotected void finish()
throws java.io.IOException
java.io.IOExceptionprotected boolean receive(io.netty.buffer.ByteBuf byteBuf)
throws java.io.IOException
java.io.IOException