io.netty.resolver

Class AbstractAddressResolver<T extends SocketAddress>

java.lang.Object

io.netty.resolver.AbstractAddressResolver<T>

All Implemented Interfaces:

AddressResolver<T>, Closeable, AutoCloseable

Direct Known Subclasses:

InetSocketAddressResolver, NoopAddressResolver

@UnstableApi
public abstract class AbstractAddressResolver<T extends SocketAddress>
extends Object
implements AddressResolver<T>

A skeletal AddressResolver implementation.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractAddressResolver(EventExecutor executor)
protected	AbstractAddressResolver(EventExecutor executor, Class<? extends T> addressType)

Method Summary

Modifier and Type	Method and Description
void	close() Closes all the resources allocated and used by this resolver.
protected abstract boolean	doIsResolved(T address) Invoked by isResolved(SocketAddress) to check if the specified address has been resolved already.
protected abstract void	doResolve(T unresolvedAddress, Promise<T> promise) Invoked by resolve(SocketAddress) to perform the actual name resolution.
protected abstract void	doResolveAll(T unresolvedAddress, Promise<List<T>> promise) Invoked by resolveAll(SocketAddress) to perform the actual name resolution.
protected EventExecutor	executor() Returns the EventExecutor which is used to notify the listeners of the Future returned by resolve(SocketAddress).
boolean	isResolved(SocketAddress address) Returns true if and only if the specified address has been resolved.
boolean	isSupported(SocketAddress address) Returns true if and only if the specified address is supported by this resolved.
Future<T>	resolve(SocketAddress address) Resolves the specified address.
Future<T>	resolve(SocketAddress address, Promise<T> promise) Resolves the specified address.
Future<List<T>>	resolveAll(SocketAddress address) Resolves the specified address.
Future<List<T>>	resolveAll(SocketAddress address, Promise<List<T>> promise) Resolves the specified address.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractAddressResolver

protected AbstractAddressResolver(EventExecutor executor)

Parameters:

executor - the EventExecutor which is used to notify the listeners of the Future returned by resolve(SocketAddress)

AbstractAddressResolver

protected AbstractAddressResolver(EventExecutor executor,
                                  Class<? extends T> addressType)

Parameters:

executor - the EventExecutor which is used to notify the listeners of the Future returned by resolve(SocketAddress)

addressType - the type of the SocketAddress supported by this resolver

Method Detail

executor

protected EventExecutor executor()

Returns the EventExecutor which is used to notify the listeners of the Future returned by resolve(SocketAddress).

isSupported

public boolean isSupported(SocketAddress address)

Description copied from interface: AddressResolver

Returns true if and only if the specified address is supported by this resolved.

Specified by:

isSupported in interface AddressResolver<T extends SocketAddress>

isResolved

public final boolean isResolved(SocketAddress address)

Description copied from interface: AddressResolver

Returns true if and only if the specified address has been resolved.

Specified by:

isResolved in interface AddressResolver<T extends SocketAddress>

doIsResolved

protected abstract boolean doIsResolved(T address)

Invoked by isResolved(SocketAddress) to check if the specified address has been resolved already.

resolve

public final Future<T> resolve(SocketAddress address)

Description copied from interface: AddressResolver

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Specified by:

resolve in interface AddressResolver<T extends SocketAddress>

Parameters:

address - the address to resolve

Returns:

the SocketAddress as the result of the resolution

resolve

public final Future<T> resolve(SocketAddress address,
                               Promise<T> promise)

Description copied from interface: AddressResolver

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Specified by:

resolve in interface AddressResolver<T extends SocketAddress>

Parameters:

address - the address to resolve

promise - the Promise which will be fulfilled when the name resolution is finished

Returns:

the SocketAddress as the result of the resolution

resolveAll

public final Future<List<T>> resolveAll(SocketAddress address)

Description copied from interface: AddressResolver

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Specified by:

resolveAll in interface AddressResolver<T extends SocketAddress>

Parameters:

address - the address to resolve

Returns:

the list of the SocketAddresses as the result of the resolution

resolveAll

public final Future<List<T>> resolveAll(SocketAddress address,
                                        Promise<List<T>> promise)

Description copied from interface: AddressResolver

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Specified by:

resolveAll in interface AddressResolver<T extends SocketAddress>

Parameters:

address - the address to resolve

promise - the Promise which will be fulfilled when the name resolution is finished

Returns:

the list of the SocketAddresses as the result of the resolution

doResolve

protected abstract void doResolve(T unresolvedAddress,
                                  Promise<T> promise)
                           throws Exception

Invoked by resolve(SocketAddress) to perform the actual name resolution.

Throws:

Exception

doResolveAll

protected abstract void doResolveAll(T unresolvedAddress,
                                     Promise<List<T>> promise)
                              throws Exception

Invoked by resolveAll(SocketAddress) to perform the actual name resolution.

Throws:

Exception

close

public void close()

Description copied from interface: AddressResolver

Closes all the resources allocated and used by this resolver.

Specified by:

close in interface AddressResolver<T extends SocketAddress>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable