Package io.quarkus.devui.runtime.comms

Class JsonRpcRouter

java.lang.Object

io.quarkus.devui.runtime.comms.JsonRpcRouter

public class JsonRpcRouter
extends Object

Route JsonRPC message to the correct method

Field Summary

Fields

Modifier and Type	Field	Description
(package private) org.jboss.logging.Logger	logger
(package private) McpDevUIJsonRpcService	mcpDevUIJsonRpcService

Constructor Summary

Constructors

Constructor	Description
JsonRpcRouter()

Method Summary

Modifier and Type	Method	Description
void	addSocket(io.vertx.core.http.ServerWebSocket socket)
Optional<io.quarkus.assistant.runtime.dev.Assistant>	defaultAssistant()
Map<String,JsonRpcMethod>	getDeploymentMethodsMap()
Map<String,JsonRpcMethod>	getDeploymentSubscriptionsMap()
JsonMapper	getJsonMapper()
JsonRpcCodec	getJsonRpcCodec()
Map<String,JsonRpcMethod>	getRecordedMethodsMap()
Map<String,JsonRpcMethod>	getRecordedSubscriptionsMap()
Map<String,JsonRpcMethod>	getRuntimeMethodsMap()
Map<String,JsonRpcMethod>	getRuntimeSubscriptionMap()
void	initializeCodec(JsonMapper jsonMapper)
boolean	isEnabled(JsonRpcRequest jsonRpcRequest)
(package private) void	onStart(io.quarkus.runtime.StartupEvent ev)
void	populateJsonRpcEndpoints(Map<String,JsonRpcMethod> runtimeMethods, Map<String,JsonRpcMethod> runtimeSubscriptions, Map<String,JsonRpcMethod> deploymentMethods, Map<String,JsonRpcMethod> deploymentSubscriptions, Map<String,JsonRpcMethod> recordedMethods, Map<String,JsonRpcMethod> recordedSubscriptions)	This gets populated at build time so the the routes knows all json-rpc endpoints.
void	route(JsonRpcRequest jsonRpcRequest, JsonRpcResponseWriter jrrw)

Methods inherited from class java.lang.Object

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

Field Details

mcpDevUIJsonRpcService

@Inject
McpDevUIJsonRpcService mcpDevUIJsonRpcService

logger

@Inject
org.jboss.logging.Logger logger

Constructor Details

JsonRpcRouter

public JsonRpcRouter()

Method Details

defaultAssistant

@Produces
public Optional<io.quarkus.assistant.runtime.dev.Assistant> defaultAssistant()

populateJsonRpcEndpoints

public void populateJsonRpcEndpoints(Map<String,JsonRpcMethod> runtimeMethods,
 Map<String,JsonRpcMethod> runtimeSubscriptions,
 Map<String,JsonRpcMethod> deploymentMethods,
 Map<String,JsonRpcMethod> deploymentSubscriptions,
 Map<String,JsonRpcMethod> recordedMethods,
 Map<String,JsonRpcMethod> recordedSubscriptions)

This gets populated at build time so the the routes knows all json-rpc endpoints.

Parameters:

runtimeMethods -

runtimeSubscriptions -

deploymentMethods -

deploymentSubscriptions -

recordedMethods -

recordedSubscriptions -

initializeCodec

public void initializeCodec(JsonMapper jsonMapper)

addSocket

public void addSocket(io.vertx.core.http.ServerWebSocket socket)

getJsonRpcCodec

@Produces
public JsonRpcCodec getJsonRpcCodec()

getRuntimeMethodsMap

public Map<String,JsonRpcMethod> getRuntimeMethodsMap()

getRuntimeSubscriptionMap

public Map<String,JsonRpcMethod> getRuntimeSubscriptionMap()

getDeploymentMethodsMap

public Map<String,JsonRpcMethod> getDeploymentMethodsMap()

getDeploymentSubscriptionsMap

public Map<String,JsonRpcMethod> getDeploymentSubscriptionsMap()

getRecordedMethodsMap

public Map<String,JsonRpcMethod> getRecordedMethodsMap()

getRecordedSubscriptionsMap

public Map<String,JsonRpcMethod> getRecordedSubscriptionsMap()

onStart

void onStart(@Observes
 io.quarkus.runtime.StartupEvent ev)

route

public void route(JsonRpcRequest jsonRpcRequest,
 JsonRpcResponseWriter jrrw)

isEnabled

public boolean isEnabled(JsonRpcRequest jsonRpcRequest)

getJsonMapper

public JsonMapper getJsonMapper()