Package io.kroxylicious.proxy.internal.net

Class NetworkUnbindRequest

java.lang.Object

io.kroxylicious.proxy.internal.net.NetworkBindingOperation<Void>

io.kroxylicious.proxy.internal.net.NetworkUnbindRequest

public class NetworkUnbindRequest
extends NetworkBindingOperation<Void>

Request for a network endpoint to be unbound.

Field Summary

Fields inherited from class io.kroxylicious.proxy.internal.net.NetworkBindingOperation

tls

Constructor Summary

Constructors

Constructor	Description
NetworkUnbindRequest(boolean tls, io.netty.channel.Channel channel, CompletableFuture<Void> future)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	getFuture()	The future that signals the completion of the network binding operation.
void	performBindingOperation(io.netty.bootstrap.ServerBootstrap serverBootstrap, ExecutorService executorService)	Performs the binding operation.
int	port()	The port associated with the binding operation.

Methods inherited from class io.kroxylicious.proxy.internal.net.NetworkBindingOperation

tls

Methods inherited from class java.lang.Object

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

Constructor Details

NetworkUnbindRequest

public NetworkUnbindRequest(boolean tls,
 io.netty.channel.Channel channel,
 CompletableFuture<Void> future)

Method Details

port

public int port()

Description copied from class: NetworkBindingOperation

The port associated with the binding operation.

Specified by:

port in class NetworkBindingOperation<Void>

Returns:

port

performBindingOperation

public void performBindingOperation(io.netty.bootstrap.ServerBootstrap serverBootstrap,
 ExecutorService executorService)

Description copied from class: NetworkBindingOperation

Performs the binding operation. Implementations must organise of the future provided by NetworkBindingOperation.getFuture() to be CompletableFuture.complete(Object) when the binding operation completes successfully. If the binding operations fails, the future must be CompletableFuture.completeExceptionally(Throwable).
If the implementation makes use of FutureListener, the implementation of the GenericFutureListener.operationComplete(Future) method must delegate work to the executorService rather than occupy the Netty owned worker thread.

Specified by:

performBindingOperation in class NetworkBindingOperation<Void>

Parameters:

serverBootstrap - server bootstrap on which the binding operations must be performed.

executorService - executor service

getFuture

public CompletableFuture<Void> getFuture()

Description copied from class: NetworkBindingOperation

The future that signals the completion of the network binding operation.

Specified by:

getFuture in class NetworkBindingOperation<Void>

Returns:

completable future