com.ibasco.agql.protocols.valve.source.query.rcon

Class SourceRconChannelRegistry

java.lang.Object

com.ibasco.agql.protocols.valve.source.query.rcon.SourceRconChannelRegistry

All Implemented Interfaces:

ChannelRegistry

public class SourceRconChannelRegistry
extends Object
implements ChannelRegistry

Default implementation for ChannelRegistry. Uses a SetMultimap to store managed netty based Channel instances.

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Constructor and Description
SourceRconChannelRegistry()

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceRconChannelRegistry

public SourceRconChannelRegistry()

Method Detail

register

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

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

Specified by:

register in interface ChannelRegistry

Parameters:

channel - The Channel to be registered

Throws:

ChannelRegistrationException - If the registration fails

unregister

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

Unregister a Channel. This method is thread-safe.

Specified by:

unregister in interface ChannelRegistry

Parameters:

channel - The Channel to be unregistered

Returns:

true if the Channel was successfuly unregistred.

isRegistered

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

Check if Channel is registered by this instance.

Specified by:

isRegistered in interface ChannelRegistry

Parameters:

channel - The Channel to check.

Returns:

true if the Channel is registered by this instance.

getEntries

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

getEntries.

Specified by:

getEntries in interface ChannelRegistry

Returns:

a Set object

getAddresses

public Set<InetSocketAddress> getAddresses()

A unique set of registered InetSocketAddress

Specified by:

getAddresses in interface ChannelRegistry

Returns:

a Set object

getChannels

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

The Channel's acquired for the specified InetSocketAddress

Specified by:

getChannels in interface ChannelRegistry

Parameters:

address - The InetSocketAddress to be used for the lookup

Returns:

a Set of Channel instances acquired for the address

getCount

public int getCount(InetSocketAddress address)

The number of Channel registered for the specified InetSocketAddress

Specified by:

getCount in interface ChannelRegistry

Parameters:

address - The InetSocketAddress to lookup

Returns:

The total number of registered Channel for the specified address