Module jakarta.websocket.client
Package jakarta.websocket

Class Endpoint

java.lang.Object
jakarta.websocket.Endpoint
Direct Known Subclasses:
WebsocketEndpoint
public abstract class Endpoint extends Object
The Web Socket Endpoint represents an object that can handle websocket conversations. Developers may extend this class in order to implement a programmatic websocket endpoint. The Endpoint class holds lifecycle methods that may be overridden to intercept websocket open, error and close events. By implementing the onOpen method, the programmatic endpoint gains access to the Session object, to which the developer may add MessageHandler implementations in order to intercept incoming websocket messages. Each instance of a websocket endpoint is guaranteed not to be called by more than one thread at a time per active connection.

If deployed as a client endpoint, it will be instantiated once for the single connection to the server.

When deployed as a server endpoint, the implementation uses the jakarta.websocket.server.ServerEndpointConfig.Configurator#getEndpointInstance method to obtain the endpoint instance it will use for each new client connection. If the developer uses the default jakarta.websocket.server.ServerEndpointConfig.Configurator, there will be precisely one endpoint instance per active client connection. Consequently, in this typical case, when implementing/overriding the methods of Endpoint, the developer is guaranteed that there will be at most one thread calling each endpoint instance at a time.

If the developer provides a custom jakarta.websocket.server.ServerEndpointConfig.Configurator which overrides the default policy for endpoint instance creation, for example, using a single Endpoint instance for multiple client connections, the developer may need to write code that can execute concurrently.

Here is an example of a simple endpoint that echoes any incoming text message back to the sender. 

 
 public class EchoServer extends Endpoint {

     @Override
     public void onOpen(Session session, EndpointConfig config) {
         final RemoteEndpoint.Basic remote = session.getBasicRemote();
         session.addMessageHandler(String.class, new MessageHandler.Whole<String>() {
             public void onMessage(String text) {
                 try {
                     remote.sendText("Got your message (" + text + "). Thanks !");
                 } catch (IOException ioe) {
                     // handle send failure here
                 }
             }
         });
     }

 }