Package org.yamcs.http
Class WebSocketServerMessageHandler
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelOutboundHandlerAdapter
org.yamcs.http.WebSocketServerMessageHandler
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelOutboundHandler
public class WebSocketServerMessageHandler
extends io.netty.channel.ChannelOutboundHandlerAdapter
Encodes
WebSocketServerMessageHandler.InternalServerMessage
to either BinaryWebSocketFrame
or TextWebSocketFrame
depending
if the protobuf or json has to be sent.
It takes care of the message priorities, dropping messages with low priority if they would exceed the high water mark
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
static class
static enum
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
io.netty.channel.ChannelHandler.Sharable
-
Constructor Summary
ConstructorDescriptionWebSocketServerMessageHandler
(HttpServer httpServer, boolean protobuf, long highWriteBufferWaterMark) -
Method Summary
Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter
bind, close, connect, deregister, disconnect, flush, read
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
exceptionCaught, handlerAdded, handlerRemoved
-
Constructor Details
-
WebSocketServerMessageHandler
public WebSocketServerMessageHandler(HttpServer httpServer, boolean protobuf, long highWriteBufferWaterMark)
-
-
Method Details
-
write
public void write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise) throws Exception - Specified by:
write
in interfaceio.netty.channel.ChannelOutboundHandler
- Overrides:
write
in classio.netty.channel.ChannelOutboundHandlerAdapter
- Throws:
Exception
-