Package org.springframework.web.reactive.socket.adapter

Class JettyWebSocketHandlerAdapter

java.lang.Object

org.springframework.web.reactive.socket.adapter.JettyWebSocketHandlerAdapter

All Implemented Interfaces:

org.eclipse.jetty.websocket.api.Session.Listener

public class JettyWebSocketHandlerAdapter
extends Object
implements org.eclipse.jetty.websocket.api.Session.Listener

Jetty Session.Listener handler that delegates events to a reactive WebSocketHandler and its session.

Since:

5.0

Author:

Violeta Georgieva, Rossen Stoyanchev

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.websocket.api.Session.Listener

org.eclipse.jetty.websocket.api.Session.Listener.Abstract, org.eclipse.jetty.websocket.api.Session.Listener.AbstractAutoDemanding, org.eclipse.jetty.websocket.api.Session.Listener.AutoDemanding

Constructor Summary

Constructors

Constructor	Description
JettyWebSocketHandlerAdapter(WebSocketHandler handler, Function<org.eclipse.jetty.websocket.api.Session,JettyWebSocketSession> sessionFactory)

Method Summary

Modifier and Type	Method	Description
void	onWebSocketBinary(ByteBuffer byteBuffer, org.eclipse.jetty.websocket.api.Callback callback)
void	onWebSocketClose(int statusCode, String reason)
void	onWebSocketError(Throwable cause)
void	onWebSocketOpen(org.eclipse.jetty.websocket.api.Session session)
void	onWebSocketPong(ByteBuffer payload)
void	onWebSocketText(String message)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.websocket.api.Session.Listener

onWebSocketFrame, onWebSocketPartialBinary, onWebSocketPartialText, onWebSocketPing

Constructor Details

JettyWebSocketHandlerAdapter

public JettyWebSocketHandlerAdapter(WebSocketHandler handler,
 Function<org.eclipse.jetty.websocket.api.Session,JettyWebSocketSession> sessionFactory)

Method Details

onWebSocketOpen

public void onWebSocketOpen(org.eclipse.jetty.websocket.api.Session session)

Specified by:

onWebSocketOpen in interface org.eclipse.jetty.websocket.api.Session.Listener

onWebSocketText

public void onWebSocketText(String message)

Specified by:

onWebSocketText in interface org.eclipse.jetty.websocket.api.Session.Listener

onWebSocketBinary

public void onWebSocketBinary(ByteBuffer byteBuffer,
 org.eclipse.jetty.websocket.api.Callback callback)

Specified by:

onWebSocketBinary in interface org.eclipse.jetty.websocket.api.Session.Listener

onWebSocketPong

public void onWebSocketPong(ByteBuffer payload)

Specified by:

onWebSocketPong in interface org.eclipse.jetty.websocket.api.Session.Listener

onWebSocketClose

public void onWebSocketClose(int statusCode,
 String reason)

Specified by:

onWebSocketClose in interface org.eclipse.jetty.websocket.api.Session.Listener

onWebSocketError

public void onWebSocketError(Throwable cause)

Specified by:

onWebSocketError in interface org.eclipse.jetty.websocket.api.Session.Listener