@ChannelHandler.Sharable
public class WsGremlinBinaryRequestDecoder
extends io.netty.handler.codec.MessageToMessageDecoder<io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame>
BinaryWebSocketFrame
. Binary-based frames assume that the format is encoded
in the first initial bytes of the message. From there the proper serializer can be chosen and the message
can then be deserialized.Constructor and Description |
---|
WsGremlinBinaryRequestDecoder(Map<String,MessageSerializer<?>> serializers) |
Modifier and Type | Method and Description |
---|---|
protected void |
decode(io.netty.channel.ChannelHandlerContext channelHandlerContext,
io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame frame,
List<Object> objects) |
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
public WsGremlinBinaryRequestDecoder(Map<String,MessageSerializer<?>> serializers)
protected void decode(io.netty.channel.ChannelHandlerContext channelHandlerContext, io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame frame, List<Object> objects) throws Exception
decode
in class io.netty.handler.codec.MessageToMessageDecoder<io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame>
Exception
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.