services.moleculer.httpclient

Interface WebSocketHandler

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface WebSocketHandler

WebSocket message receiver. Simple usage:

 client.ws("ws://server/path", msg -> {
 
     // Message received; "msg" is a JSON structure
     String value = msg.get("key", "defaultValue");
 
 });
 

Advanced usage:

 client.ws("ws://server/path", new WebSocketHandler() {
 
     public void onMessage(Tree message) {
        // Message received
     }
 
     public void onOpen(WebSocket webSocket) {
        // WebSocket opened
     }
 
     public void onError(Throwable t) {
        // Error occured
     }
 
     public void onClose(WebSocket webSocket, int code, String reason) {
        // WebSocket closed
     }
 
 });
 

Method Summary

Modifier and Type	Method and Description
default void	onClose(org.asynchttpclient.ws.WebSocket webSocket, int code, java.lang.String reason)
default void	onError(java.lang.Throwable t)
void	onMessage(io.datatree.Tree message)
default void	onOpen(org.asynchttpclient.ws.WebSocket webSocket)

Method Detail

onMessage

void onMessage(io.datatree.Tree message)

onOpen

default void onOpen(org.asynchttpclient.ws.WebSocket webSocket)

onError

default void onError(java.lang.Throwable t)

onClose

default void onClose(org.asynchttpclient.ws.WebSocket webSocket,
                     int code,
                     java.lang.String reason)