Package dev.agenor.tools.console

Class WebSocketHandler

java.lang.Object

dev.agenor.tools.console.WebSocketHandler

All Implemented Interfaces:

ConsoleEventListener, org.eclipse.jetty.websocket.server.JettyWebSocketCreator

public class WebSocketHandler
extends Object
implements org.eclipse.jetty.websocket.server.JettyWebSocketCreator, ConsoleEventListener

WebSocket handler for real-time updates. Events: - agent.started - agent.stopped - message.sent - message.received - behavior.executed - error.occurred

Constructor Summary

Constructors

Constructor	Description
WebSocketHandler(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
void	broadcast(String type, Object data)	Broadcast event to all connected clients.
Object	createWebSocket(org.eclipse.jetty.websocket.server.JettyServerUpgradeRequest req, org.eclipse.jetty.websocket.server.JettyServerUpgradeResponse resp)
void	onAgentStarted(String agentId, String agentName)
void	onAgentStopped(String agentId, String agentName)
void	onBehaviorExecuted(String agentId, String behaviorId, long durationMs, boolean success, String error)
void	onError(String source, String message)
void	onMessageSent(String messageId, String topic, String senderId)

Methods inherited from class java.lang.Object

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

Constructor Details

WebSocketHandler

public WebSocketHandler(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

createWebSocket

public Object createWebSocket(org.eclipse.jetty.websocket.server.JettyServerUpgradeRequest req,
 org.eclipse.jetty.websocket.server.JettyServerUpgradeResponse resp)

Specified by:

createWebSocket in interface org.eclipse.jetty.websocket.server.JettyWebSocketCreator

onAgentStarted

public void onAgentStarted(String agentId,
 String agentName)

Specified by:

onAgentStarted in interface ConsoleEventListener

onAgentStopped

public void onAgentStopped(String agentId,
 String agentName)

Specified by:

onAgentStopped in interface ConsoleEventListener

onMessageSent

public void onMessageSent(String messageId,
 String topic,
 String senderId)

Specified by:

onMessageSent in interface ConsoleEventListener

onError

public void onError(String source,
 String message)

Specified by:

onError in interface ConsoleEventListener

onBehaviorExecuted

public void onBehaviorExecuted(String agentId,
 String behaviorId,
 long durationMs,
 boolean success,
 String error)

Specified by:

onBehaviorExecuted in interface ConsoleEventListener

broadcast

public void broadcast(String type,
 Object data)

Broadcast event to all connected clients.