org.thales.punch.libraries.netty.groups

Class Group<T>

java.lang.Object

org.thales.punch.libraries.netty.groups.Group<T>

Type Parameters:

T - the NettyTuple used as part of this group.

All Implemented Interfaces:

Comparable<Group<T>>

public class Group<T>
extends Object
implements Comparable<Group<T>>

A Group of destination. Its weight is the sum of all destinations it contains.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.logging.log4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
Group(Groups<T> groups, String name)

Method Summary

Modifier and Type	Method and Description
Group<T>	add(Destination<T> d)
int	compareTo(Group<T> o)
void	connected(Destination<T> d) Callback whenever the connection to one destination suceeded.
void	disconnected(Destination<T> d) Callback whenever the connection to one destination failed.
long	getConfiguredWeight()
long	getEffectiveWeight()
String	getName()
void	start() Start this group.
void	stop() Stop this group
String	toString()
boolean	write(T packet, Object context) Write a packet to one of the destination available in a group.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static org.apache.logging.log4j.Logger logger

Constructor Detail

Group

public Group(Groups<T> groups,
             String name)

Method Detail

add

public Group<T> add(Destination<T> d)

getEffectiveWeight

public long getEffectiveWeight()

Returns:

the current weight, as the sum of all connected clients.

getConfiguredWeight

public long getConfiguredWeight()

Returns:

the configured weight, i.e. the sum of all configured destination, connected or not.

connected

public void connected(Destination<T> d)

Callback whenever the connection to one destination suceeded.

Parameters:

d - the newly connected destination

disconnected

public void disconnected(Destination<T> d)

Callback whenever the connection to one destination failed.

Parameters:

d - the lost destination

compareTo

public int compareTo(Group<T> o)

Specified by:

compareTo in interface Comparable<Group<T>>

start

public void start()

Start this group. This launche one thread per destination. Each in charge of connecting to the peer , and if that fails, keep retrying.

stop

public void stop()

Stop this group

toString

public String toString()

Overrides:

toString in class Object

getName

public String getName()

write

public boolean write(T packet,
                     Object context)

Write a packet to one of the destination available in a group. This function performs a round robin load balancing.

Parameters:

packet - the data to send

context - the context object to be associated to the acknowledgement

Returns:

true if the packet is in the sending pipe of one of the destination. Which of course means nothing or something depending on the underlying client (TCP or Lumberjack). Flase if no destination could handle the packet.