Package io.micronaut.mcp.server.registry

Class ResourceRegistry

java.lang.Object

io.micronaut.mcp.server.registry.ResourceRegistry

@Requires(beans=McpServerConfiguration.class)
@Singleton
@Internal
public final class ResourceRegistry
extends Object

The registry of Resource-annotated methods. Produces MCP Resource specifications with handlers that invoke the annotated methods.

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.micronaut.context.BeanContext	beanContext
protected static final String	DESCRIPTION_PROPERTY
protected static final String	KEY_TYPE
protected static final String	MEMBER_DESCRIPTION
protected static final String	MEMBER_NAME
protected static final String	MEMBER_TITLE
protected final List<io.micronaut.mcp.server.registry.AbstractMcpMethodRegistry.Method<Object>>	methods
protected static final String	MIME_TYPE_PROPERTY
protected static final String	NAME_PROPERTY
protected static final String	TITLE_PROPERTY
protected static final String	URI_PROPERTY
protected static final String	URI_TEMPLATE_PROPERTY

Constructor Summary

Constructors

Constructor	Description
ResourceRegistry(List<McpErrorExceptionMapper<? extends Throwable>> exceptionMappers, io.micronaut.core.bind.ArgumentBinderRegistry<io.modelcontextprotocol.spec.McpSchema.ReadResourceRequest> argumentBinderRegistry, io.micronaut.context.BeanContext beanContext)

Method Summary

Modifier and Type	Method	Description
final void	addMethod(io.micronaut.inject.BeanDefinition<?> beanDefinition, io.micronaut.inject.ExecutableMethod<?,?> method)	Adds a new method to the registry by associating it with a given bean definition.
protected final Stream<io.micronaut.mcp.server.registry.AbstractMcpMethodRegistry.Method<Object>>	drainMethods()	Returns a stream of the methods currently stored in the registry.
List<io.modelcontextprotocol.server.McpServerFeatures.AsyncResourceSpecification>	getAsyncSpecs()
List<io.modelcontextprotocol.server.McpStatelessServerFeatures.AsyncResourceSpecification>	getStatelessAsyncSpecs()
List<io.modelcontextprotocol.server.McpStatelessServerFeatures.SyncResourceSpecification>	getStatelessSyncSpecs()
List<io.modelcontextprotocol.server.McpServerFeatures.SyncResourceSpecification>	getSyncSpecs()
boolean	isNotEmpty()
protected io.modelcontextprotocol.spec.McpError	mcpError(Exception ex)
protected Map<io.micronaut.core.type.Argument<?>,Object>	prepareBoundVariables(io.micronaut.inject.ExecutableMethod<?,?> executable, List<?> parameters)
protected @Nullable io.modelcontextprotocol.common.McpTransportContext	resolveMcpTransportContext(Object ctx)

Methods inherited from class java.lang.Object

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

Field Details

MEMBER_DESCRIPTION

protected static final String MEMBER_DESCRIPTION

See Also:

• Constant Field Values

KEY_TYPE

protected static final String KEY_TYPE

See Also:

• Constant Field Values

DESCRIPTION_PROPERTY

protected static final String DESCRIPTION_PROPERTY

See Also:

• Constant Field Values

MIME_TYPE_PROPERTY

protected static final String MIME_TYPE_PROPERTY

See Also:

• Constant Field Values

NAME_PROPERTY

protected static final String NAME_PROPERTY

See Also:

• Constant Field Values

TITLE_PROPERTY

protected static final String TITLE_PROPERTY

See Also:

• Constant Field Values

URI_PROPERTY

protected static final String URI_PROPERTY

See Also:

• Constant Field Values

URI_TEMPLATE_PROPERTY

protected static final String URI_TEMPLATE_PROPERTY

See Also:

• Constant Field Values

MEMBER_NAME

protected static final String MEMBER_NAME

See Also:

• Constant Field Values

MEMBER_TITLE

protected static final String MEMBER_TITLE

See Also:

• Constant Field Values

methods

protected final List<io.micronaut.mcp.server.registry.AbstractMcpMethodRegistry.Method<Object>> methods

beanContext

protected final io.micronaut.context.BeanContext beanContext

Constructor Details

ResourceRegistry

public ResourceRegistry(List<McpErrorExceptionMapper<? extends Throwable>> exceptionMappers,
 io.micronaut.core.bind.ArgumentBinderRegistry<io.modelcontextprotocol.spec.McpSchema.ReadResourceRequest> argumentBinderRegistry,
 io.micronaut.context.BeanContext beanContext)

Method Details

getSyncSpecs

public List<io.modelcontextprotocol.server.McpServerFeatures.SyncResourceSpecification> getSyncSpecs()

getAsyncSpecs

public List<io.modelcontextprotocol.server.McpServerFeatures.AsyncResourceSpecification> getAsyncSpecs()

getStatelessSyncSpecs

public List<io.modelcontextprotocol.server.McpStatelessServerFeatures.SyncResourceSpecification> getStatelessSyncSpecs()

getStatelessAsyncSpecs

public List<io.modelcontextprotocol.server.McpStatelessServerFeatures.AsyncResourceSpecification> getStatelessAsyncSpecs()

isNotEmpty

public boolean isNotEmpty()

addMethod

public final void addMethod(io.micronaut.inject.BeanDefinition<?> beanDefinition,
 io.micronaut.inject.ExecutableMethod<?,?> method)

Adds a new method to the registry by associating it with a given bean definition.

Parameters:

beanDefinition - the bean definition that declares or provides the method

method - the executable method to be added to the registry

drainMethods

protected final Stream<io.micronaut.mcp.server.registry.AbstractMcpMethodRegistry.Method<Object>> drainMethods()

Returns a stream of the methods currently stored in the registry. After the stream is consumed or closed, the underlying list of methods will be cleared.

Returns:

a stream of methods from the registry

mcpError

protected io.modelcontextprotocol.spec.McpError mcpError(Exception ex)

prepareBoundVariables

protected Map<io.micronaut.core.type.Argument<?>,Object> prepareBoundVariables(io.micronaut.inject.ExecutableMethod<?,?> executable,
 List<?> parameters)

resolveMcpTransportContext

@Nullable
protected @Nullable io.modelcontextprotocol.common.McpTransportContext resolveMcpTransportContext(Object ctx)