com.ibasco.agql.core

Interface ChannelRegistry

All Known Implementing Classes:

SourceRconChannelRegistry

public interface ChannelRegistry

A registry/store for all managed netty based Channel. Implementation of this class must be thread-safe

Author:

Rafael Luis Ibasco

Method Summary

Modifier and Type	Method and Description
Set<InetSocketAddress>	getAddresses() A unique set of registered InetSocketAddress
Set<io.netty.channel.Channel>	getChannels(InetSocketAddress address) The Channel's acquired for the specified InetSocketAddress
int	getCount(InetSocketAddress address) The number of Channel registered for the specified InetSocketAddress
Set<Map.Entry<InetSocketAddress,io.netty.channel.Channel>>	getEntries() getEntries.
boolean	isRegistered(io.netty.channel.Channel channel) Check if Channel is registered by this instance.
void	register(io.netty.channel.Channel channel) Register a newly acquired Channel.
boolean	unregister(io.netty.channel.Channel channel) Unregister a Channel.

Method Detail

register

void register(io.netty.channel.Channel channel)
       throws ChannelRegistrationException

Register a newly acquired Channel. This method is thread-safe.

Parameters:

channel - The Channel to be registered

Throws:

ChannelRegistrationException - If the registration fails

unregister

boolean unregister(io.netty.channel.Channel channel)

Unregister a Channel. This method is thread-safe.

Parameters:

channel - The Channel to be unregistered

Returns:

true if the Channel was successfuly unregistred.

isRegistered

boolean isRegistered(io.netty.channel.Channel channel)

Check if Channel is registered by this instance.

Parameters:

channel - The Channel to check.

Returns:

true if the Channel is registered by this instance.

getEntries

Set<Map.Entry<InetSocketAddress,io.netty.channel.Channel>> getEntries()

getEntries.

Returns:

a Set object

getAddresses

Set<InetSocketAddress> getAddresses()

A unique set of registered InetSocketAddress

Returns:

a Set object

getChannels

Set<io.netty.channel.Channel> getChannels(InetSocketAddress address)

The Channel's acquired for the specified InetSocketAddress

Parameters:

address - The InetSocketAddress to be used for the lookup

Returns:

a Set of Channel instances acquired for the address

getCount

int getCount(InetSocketAddress address)

The number of Channel registered for the specified InetSocketAddress

Parameters:

address - The InetSocketAddress to lookup

Returns:

The total number of registered Channel for the specified address