Package io.micronaut.http.client.netty

Class ConnectionManager

java.lang.Object

io.micronaut.http.client.netty.ConnectionManager

@Internal
public class ConnectionManager
extends Object

Connection manager for DefaultHttpClient. This class manages the lifecycle of netty channels (wrapped in ConnectionManager.PoolHandles), including pooling and timeouts.
Note: This class is public for use in micronaut-oracle-cloud.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConnectionManager.PoolHandle	Handle for a pooled connection.

Method Summary

Modifier and Type	Method	Description
final io.netty.buffer.ByteBufAllocator	alloc()	Allocator for this connection manager.
final ExecutionFlow<ConnectionManager.PoolHandle>	connect(DefaultHttpClient.RequestKey requestKey, @Nullable BlockHint blockHint)	Get a connection for non-websocket http client methods.
final ExecutionFlow<ConnectionManager.PoolHandle>	connect(DefaultHttpClient.RequestKey requestKey, @Nullable BlockHint blockHint, @Nullable AtomicReference<ScheduledExecutorService> preferredScheduler)	Get a connection for non-websocket http client methods.
final boolean	isRunning()
final void	shutdown()
final void	start()

Methods inherited from class java.lang.Object

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

Method Details

alloc

public final io.netty.buffer.ByteBufAllocator alloc()

Allocator for this connection manager. Used by micronaut-oracle-cloud.

Returns:

The configured allocator

start

public final void start()

See Also:

• DefaultHttpClient.start()

shutdown

public final void shutdown()

See Also:

• DefaultHttpClient.stop()

isRunning

public final boolean isRunning()

Returns:

Whether this connection manager is still running and can serve requests

See Also:

• DefaultHttpClient.isRunning()

connect

public final ExecutionFlow<ConnectionManager.PoolHandle> connect(DefaultHttpClient.RequestKey requestKey,
 @Nullable
 @Nullable BlockHint blockHint)

Get a connection for non-websocket http client methods.

Parameters:

requestKey - The remote to connect to

blockHint - Optional information about what threads are blocked for this connection request

Returns:

A mono that will complete once the channel is ready for transmission

connect

public final ExecutionFlow<ConnectionManager.PoolHandle> connect(DefaultHttpClient.RequestKey requestKey,
 @Nullable
 @Nullable BlockHint blockHint,
 @Nullable
 @Nullable AtomicReference<ScheduledExecutorService> preferredScheduler)

Get a connection for non-websocket http client methods.

Parameters:

requestKey - The remote to connect to

blockHint - Optional information about what threads are blocked for this connection request

preferredScheduler - Reference to set to the preferred scheduler (for timeouts) as soon as it becomes available

Returns:

A mono that will complete once the channel is ready for transmission