Package io.micronaut.http.server.netty

Interface NettyEmbeddedServices

All Known Implementing Classes:

DefaultNettyEmbeddedServerFactory

@Internal
public interface NettyEmbeddedServices

Internal interface with services required by the NettyHttpServer. e

Since:

3.1.0

Author:

graemerocher

Method Summary

Modifier and Type	Method	Description
@NonNull io.netty.channel.EventLoopGroup	createEventLoopGroup(int numThreads, @NonNull ExecutorService executorService, @Nullable Integer ioRatio)	Creates the event loop group configuration.
@NonNull io.netty.channel.EventLoopGroup	createEventLoopGroup(@NonNull EventLoopGroupConfiguration config)	Creates the event loop group configuration.
@NonNull ApplicationContext	getApplicationContext()
default @NonNull io.netty.channel.Channel	getChannelInstance(NettyChannelType type, @NonNull EventLoopGroupConfiguration workerConfig)	Gets the domain server socket channel instance.
default @NonNull io.netty.channel.Channel	getChannelInstance(NettyChannelType type, @NonNull EventLoopGroupConfiguration workerConfig, io.netty.channel.Channel parent, int fd)	Gets the domain server socket channel instance.
@NonNull ChannelOptionFactory	getChannelOptionFactory()
default @NonNull io.netty.channel.ServerChannel	getDomainServerChannelInstance(@NonNull EventLoopGroupConfiguration workerConfig)	Gets the domain server socket channel instance.
@NonNull EventLoopGroupRegistry	getEventLoopGroupRegistry()
<E> @NonNull ApplicationEventPublisher<E>	getEventPublisher(@NonNull Class<E> eventClass)	Get an event publisher for the server for the given type.
default @NonNull ExecutorSelector	getExecutorSelector()
@NonNull HttpCompressionStrategy	getHttpCompressionStrategy()
@NonNull MediaTypeCodecRegistry	getMediaTypeCodecRegistry()
MessageBodyHandlerRegistry	getMessageBodyHandlerRegistry()
@NonNull List<io.netty.channel.ChannelOutboundHandler>	getOutboundHandlers()
default @NonNull RequestArgumentSatisfier	getRequestArgumentSatisfier()
@NonNull RouteExecutor	getRouteExecutor()
default @NonNull Router	getRouter()
@NonNull io.netty.channel.socket.ServerSocketChannel	getServerSocketChannelInstance(@NonNull EventLoopGroupConfiguration workerConfig)	Gets the server socket channel instance.
@Nullable ServerSslBuilder	getServerSslBuilder()
@NonNull StaticResourceResolver	getStaticResourceResolver()
Optional<NettyServerWebSocketUpgradeHandler>	getWebSocketUpgradeHandler(NettyEmbeddedServer embeddedServer)

Method Details

getMessageBodyHandlerRegistry

MessageBodyHandlerRegistry getMessageBodyHandlerRegistry()

Returns:

The message body handler registry.

getOutboundHandlers

@NonNull
@NonNull List<io.netty.channel.ChannelOutboundHandler> getOutboundHandlers()

Returns:

The channel outbound handlers

getApplicationContext

@NonNull
@NonNull ApplicationContext getApplicationContext()

Returns:

The application context

getRequestArgumentSatisfier

@NonNull
default @NonNull RequestArgumentSatisfier getRequestArgumentSatisfier()

Returns:

The request argument satisfier

See Also:

• RequestArgumentSatisfier

getRouteExecutor

@NonNull
@NonNull RouteExecutor getRouteExecutor()

Returns:

The route executor

See Also:

• RouteExecutor

getMediaTypeCodecRegistry

@NonNull
@NonNull MediaTypeCodecRegistry getMediaTypeCodecRegistry()

Returns:

The media type code registry

See Also:

• MediaTypeCodecRegistry

getStaticResourceResolver

@NonNull
@NonNull StaticResourceResolver getStaticResourceResolver()

Returns:

The static resource resolver

See Also:

• StaticResourceResolver

getExecutorSelector

@NonNull
default @NonNull ExecutorSelector getExecutorSelector()

Returns:

The executor resolver

getServerSslBuilder

@Nullable
@Nullable ServerSslBuilder getServerSslBuilder()

Returns:

The server SSL builder or null if none is configured

See Also:

• CertificateProvidedSslBuilder

getChannelOptionFactory

@NonNull
@NonNull ChannelOptionFactory getChannelOptionFactory()

Returns:

The channel option factory

getHttpCompressionStrategy

@NonNull
@NonNull HttpCompressionStrategy getHttpCompressionStrategy()

Returns:

The http compression strategy

getWebSocketUpgradeHandler

Optional<NettyServerWebSocketUpgradeHandler> getWebSocketUpgradeHandler(NettyEmbeddedServer embeddedServer)

Parameters:

embeddedServer - The server

Returns:

The websocket upgrade handler if present

getEventLoopGroupRegistry

@NonNull
@NonNull EventLoopGroupRegistry getEventLoopGroupRegistry()

Returns:

The event loop group registry.

getRouter

@NonNull
default @NonNull Router getRouter()

Returns:

Obtains the router

createEventLoopGroup

@NonNull
@NonNull io.netty.channel.EventLoopGroup createEventLoopGroup(@NonNull
 @NonNull EventLoopGroupConfiguration config)

Creates the event loop group configuration.

Parameters:

config - The config

Returns:

The event loop group config

createEventLoopGroup

@NonNull
@NonNull io.netty.channel.EventLoopGroup createEventLoopGroup(int numThreads,
 @NonNull
 @NonNull ExecutorService executorService,
 @Nullable
 @Nullable Integer ioRatio)

Creates the event loop group configuration.

Parameters:

numThreads - The number of threads

executorService - The executor service

ioRatio - The I/O ratio

Returns:

The event loop group

getServerSocketChannelInstance

@NonNull
@NonNull io.netty.channel.socket.ServerSocketChannel getServerSocketChannelInstance(@NonNull
 @NonNull EventLoopGroupConfiguration workerConfig)

Gets the server socket channel instance.

Parameters:

workerConfig - The worker config

Returns:

The ServerSocketChannel

getDomainServerChannelInstance

@NonNull
default @NonNull io.netty.channel.ServerChannel getDomainServerChannelInstance(@NonNull
 @NonNull EventLoopGroupConfiguration workerConfig)

Gets the domain server socket channel instance.

Parameters:

workerConfig - The worker config

Returns:

The DomainSocketChannel

Throws:

UnsupportedOperationException - if domain sockets are not supported.

getChannelInstance

@NonNull
default @NonNull io.netty.channel.Channel getChannelInstance(NettyChannelType type,
 @NonNull
 @NonNull EventLoopGroupConfiguration workerConfig)

Gets the domain server socket channel instance.

Parameters:

type - The channel type to return

workerConfig - The worker config

Returns:

The channel

Throws:

UnsupportedOperationException - if domain sockets are not supported.

getChannelInstance

@NonNull
default @NonNull io.netty.channel.Channel getChannelInstance(NettyChannelType type,
 @NonNull
 @NonNull EventLoopGroupConfiguration workerConfig,
 io.netty.channel.Channel parent,
 int fd)

Gets the domain server socket channel instance.

Parameters:

type - The channel type to return

workerConfig - The worker config

parent - The parent channel, or null for no parent channel

fd - The pre-defined file descriptor

Returns:

The channel

Throws:

UnsupportedOperationException - if domain sockets are not supported.

getEventPublisher

@NonNull
<E> @NonNull ApplicationEventPublisher<E> getEventPublisher(@NonNull
 @NonNull Class<E> eventClass)

Get an event publisher for the server for the given type.

Type Parameters:

E - The event generic type

Parameters:

eventClass - The event publisher

Returns:

The event publisher