Class WebSocketMcpListener

java.lang.Object

dev.langchain4j.mcp.client.transport.websocket.WebSocketMcpListener

All Implemented Interfaces:

WebSocket.Listener

public class WebSocketMcpListener
extends Object
implements WebSocket.Listener

Constructor Summary

Constructors

Constructor	Description
WebSocketMcpListener(McpOperationHandler operationHandler, org.slf4j.Logger trafficLogger, boolean logResponses, Runnable onCloseCallback, Runnable onFailureCallback)

Method Summary

Modifier and Type	Method	Description
CompletionStage<?>	onBinary(WebSocket webSocket, ByteBuffer data, boolean last)
CompletionStage<?>	onClose(WebSocket webSocket, int statusCode, String reason)
void	onError(WebSocket webSocket, Throwable error)
void	onOpen(WebSocket webSocket)
CompletionStage<?>	onText(WebSocket webSocket, CharSequence data, boolean last)

Methods inherited from class Object

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

Methods inherited from interface WebSocket.Listener

onPing, onPong

Constructor Details

WebSocketMcpListener

public WebSocketMcpListener(McpOperationHandler operationHandler,
 org.slf4j.Logger trafficLogger,
 boolean logResponses,
 Runnable onCloseCallback,
 Runnable onFailureCallback)

Method Details

onOpen

public void onOpen(WebSocket webSocket)

Specified by:

onOpen in interface WebSocket.Listener

onText

public CompletionStage<?> onText(WebSocket webSocket,
 CharSequence data,
 boolean last)

Specified by:

onText in interface WebSocket.Listener

onClose

public CompletionStage<?> onClose(WebSocket webSocket,
 int statusCode,
 String reason)

Specified by:

onClose in interface WebSocket.Listener

onError

public void onError(WebSocket webSocket,
 Throwable error)

Specified by:

onError in interface WebSocket.Listener

onBinary

public CompletionStage<?> onBinary(WebSocket webSocket,
 ByteBuffer data,
 boolean last)

Specified by:

onBinary in interface WebSocket.Listener