Class UnisonReceiveListener

java.lang.Object
io.undertow.websockets.core.AbstractReceiveListener
com.tremolosecurity.proxy.undertow.UnisonReceiveListener
All Implemented Interfaces:
EventListener, org.xnio.ChannelListener<io.undertow.websockets.core.WebSocketChannel>
public class UnisonReceiveListener extends io.undertow.websockets.core.AbstractReceiveListener

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.xnio.ChannelListener

    org.xnio.ChannelListener.Setter<T extends Channel>, org.xnio.ChannelListener.SimpleSetter<T extends Channel>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static Charset
    charset
     
    static CharsetDecoder
    decoder
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    UnisonReceiveListener(String url, HttpFilterRequest request, jakarta.servlet.http.HttpServletResponse resp, UnisonWebSocketClientNegotiation clientNegotiation)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    initializeFromCallback(io.undertow.websockets.spi.WebSocketHttpExchange exchange, io.undertow.websockets.core.WebSocketChannel channel)
     
    protected void
    onBinary(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel messageChannel)
     
    protected void
    onClose(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel channel)
     
    protected void
    onCloseMessage(io.undertow.websockets.core.CloseMessage cm, io.undertow.websockets.core.WebSocketChannel channel)
     
    protected void
    onError(io.undertow.websockets.core.WebSocketChannel channel, Throwable error)
     
    protected void
    onFullBinaryMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message)
     
    protected void
    onFullCloseMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message)
     
    protected void
    onFullPingMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message)
     
    protected void
    onFullPongMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message)
     
    protected void
    onFullTextMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedTextMessage message)
     
    protected void
    onPing(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel channel)
     
    protected void
    onPong(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel messageChannel)
     
    protected void
    onText(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel messageChannel)
     
    void
    startConnection()
     

    Methods inherited from class io.undertow.websockets.core.AbstractReceiveListener

    bufferFullMessage, getMaxBinaryBufferSize, getMaxCloseBufferSize, getMaxPingBufferSize, getMaxPongBufferSize, getMaxTextBufferSize, handleEvent

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

  • Method Details

    • initializeFromCallback

      public void initializeFromCallback(io.undertow.websockets.spi.WebSocketHttpExchange exchange, io.undertow.websockets.core.WebSocketChannel channel) throws CancellationException, IOException
      Throws:
      CancellationException
      IOException

    • startConnection

      public void startConnection() throws IOException
      Throws:
      IOException

    • onPing

      protected void onPing(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel channel) throws IOException
      Overrides:
      onPing in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onClose

      protected void onClose(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel channel) throws IOException
      Overrides:
      onClose in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onPong

      protected void onPong(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel messageChannel) throws IOException
      Overrides:
      onPong in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onText

      protected void onText(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel messageChannel) throws IOException
      Overrides:
      onText in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onBinary

      protected void onBinary(io.undertow.websockets.core.WebSocketChannel webSocketChannel, io.undertow.websockets.core.StreamSourceFrameChannel messageChannel) throws IOException
      Overrides:
      onBinary in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onError

      protected void onError(io.undertow.websockets.core.WebSocketChannel channel, Throwable error)
      Overrides:
      onError in class io.undertow.websockets.core.AbstractReceiveListener

    • onFullTextMessage

      protected void onFullTextMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedTextMessage message) throws IOException
      Overrides:
      onFullTextMessage in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onFullBinaryMessage

      protected void onFullBinaryMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message) throws IOException
      Overrides:
      onFullBinaryMessage in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onFullPingMessage

      protected void onFullPingMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message) throws IOException
      Overrides:
      onFullPingMessage in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onFullPongMessage

      protected void onFullPongMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message) throws IOException
      Overrides:
      onFullPongMessage in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onFullCloseMessage

      protected void onFullCloseMessage(io.undertow.websockets.core.WebSocketChannel channel, io.undertow.websockets.core.BufferedBinaryMessage message) throws IOException
      Overrides:
      onFullCloseMessage in class io.undertow.websockets.core.AbstractReceiveListener
      Throws:
      IOException

    • onCloseMessage

      protected void onCloseMessage(io.undertow.websockets.core.CloseMessage cm, io.undertow.websockets.core.WebSocketChannel channel)
      Overrides:
      onCloseMessage in class io.undertow.websockets.core.AbstractReceiveListener