com.ibasco.agql.core.transport.pool

Class MessageChannelPoolMap

java.lang.Object

com.ibasco.agql.core.transport.pool.MessageChannelPoolMap

All Implemented Interfaces:

NettyChannelPoolMap<Object,NettyChannelPool>, Closeable, AutoCloseable, Iterable<Map.Entry<Object,NettyChannelPool>>

public class MessageChannelPoolMap
extends Object
implements NettyChannelPoolMap<Object,NettyChannelPool>, Iterable<Map.Entry<Object,NettyChannelPool>>

A custom ChannelPoolMap implementation that allows a custom pool key to be used for NettyChannelPool lookup.

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Constructor and Description
MessageChannelPoolMap(NettyPooledChannelFactory pooledChannelFactory) Constructor for MessageChannelPoolMap.

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	contains(Object data) Returns true if a NettyChannelPool exists for the given key.
NettyChannelPool	get(Object data) Return the NettyChannelPool for the code.
NettyChannelPoolFactory	getChannelPoolFactory() getChannelPoolFactory.
NettyPoolPropertyResolver	getResolver() getResolver.
@NotNull Iterator<Map.Entry<Object,NettyChannelPool>>	iterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

MessageChannelPoolMap

public MessageChannelPoolMap(NettyPooledChannelFactory pooledChannelFactory)

Constructor for MessageChannelPoolMap.

Parameters:

pooledChannelFactory - a NettyPooledChannelFactory object

Method Detail

get

public NettyChannelPool get(Object data)

Return the NettyChannelPool for the code. This will never return null, but create a new NettyChannelPool if non exists for they requested key.

Please note that null keys are not allowed.

Specified by:

get in interface NettyChannelPoolMap<Object,NettyChannelPool>

Parameters:

data - a K object

Returns:

a P object

contains

public boolean contains(Object data)

Returns true if a NettyChannelPool exists for the given key.

Please note that null keys are not allowed.

Specified by:

contains in interface NettyChannelPoolMap<Object,NettyChannelPool>

Parameters:

data - a K object

Returns:

a boolean

getResolver

public NettyPoolPropertyResolver getResolver()

getResolver.

Returns:

a NettyPoolPropertyResolver object

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getChannelPoolFactory

public NettyChannelPoolFactory getChannelPoolFactory()

getChannelPoolFactory.

Returns:

a NettyChannelPoolFactory object

iterator

@NotNull
public @NotNull Iterator<Map.Entry<Object,NettyChannelPool>> iterator()

Specified by:

iterator in interface Iterable<Map.Entry<Object,NettyChannelPool>>