Class TiangongWebSocketSession

java.lang.Object
tech.riemann.nif.support.tiangong.websocket.TiangongWebSocketSession
All Implemented Interfaces:
Closeable, AutoCloseable, Principal, org.springframework.web.socket.WebSocketSession
public class TiangongWebSocketSession extends Object implements org.springframework.web.socket.WebSocketSession, Principal

  • Constructor Details

    • TiangongWebSocketSession

      public TiangongWebSocketSession(io.netty.channel.Channel channel, Map<String, List<String>> handshakeHeaders)

  • Method Details

    • getId

      public String getId()
      Specified by:
      getId in interface org.springframework.web.socket.WebSocketSession

    • getName

      public String getName()
      Specified by:
      getName in interface Principal

    • getPrincipal

      public Principal getPrincipal()
      Specified by:
      getPrincipal in interface org.springframework.web.socket.WebSocketSession

    • getAcceptedProtocol

      public String getAcceptedProtocol()
      Specified by:
      getAcceptedProtocol in interface org.springframework.web.socket.WebSocketSession

    • setTextMessageSizeLimit

      public void setTextMessageSizeLimit(int messageSizeLimit)
      Specified by:
      setTextMessageSizeLimit in interface org.springframework.web.socket.WebSocketSession

    • getTextMessageSizeLimit

      public int getTextMessageSizeLimit()
      Specified by:
      getTextMessageSizeLimit in interface org.springframework.web.socket.WebSocketSession

    • setBinaryMessageSizeLimit

      public void setBinaryMessageSizeLimit(int messageSizeLimit)
      Specified by:
      setBinaryMessageSizeLimit in interface org.springframework.web.socket.WebSocketSession

    • getBinaryMessageSizeLimit

      public int getBinaryMessageSizeLimit()
      Specified by:
      getBinaryMessageSizeLimit in interface org.springframework.web.socket.WebSocketSession

    • getExtensions

      public List<org.springframework.web.socket.WebSocketExtension> getExtensions()
      Specified by:
      getExtensions in interface org.springframework.web.socket.WebSocketSession

    • getAttributes

      public Map<String,Object> getAttributes()
      Specified by:
      getAttributes in interface org.springframework.web.socket.WebSocketSession

    • getHandshakeHeaders

      public org.springframework.http.HttpHeaders getHandshakeHeaders()
      Specified by:
      getHandshakeHeaders in interface org.springframework.web.socket.WebSocketSession

    • sendMessage

      public void sendMessage(org.springframework.web.socket.WebSocketMessage<?> message) throws IOException
      Specified by:
      sendMessage in interface org.springframework.web.socket.WebSocketSession
      Throws:
      IOException

    • isOpen

      public boolean isOpen()
      Specified by:
      isOpen in interface org.springframework.web.socket.WebSocketSession

    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.springframework.web.socket.WebSocketSession
      Throws:
      IOException

    • close

      public void close(org.springframework.web.socket.CloseStatus status) throws IOException
      Specified by:
      close in interface org.springframework.web.socket.WebSocketSession
      Throws:
      IOException

    • getLocalAddress

      public InetSocketAddress getLocalAddress()
      Specified by:
      getLocalAddress in interface org.springframework.web.socket.WebSocketSession

    • getRemoteAddress

      public InetSocketAddress getRemoteAddress()
      Specified by:
      getRemoteAddress in interface org.springframework.web.socket.WebSocketSession

    • getUri

      public URI getUri()
      Specified by:
      getUri in interface org.springframework.web.socket.WebSocketSession

    • getUriPath

      public String getUriPath()

    • markClosed

      public void markClosed()

    • getChannel

      public io.netty.channel.Channel getChannel()