org.jdiameter.server.impl
Class NetworkImpl

java.lang.Object
  org.jdiameter.server.impl.NetworkImpl

All Implemented Interfaces:

Network, Wrapper, INetwork

public class NetworkImpl
extends java.lang.Object
implements INetwork

Author:

erick.svenson@yahoo.com, Alexandre Mendonca , Bartosz Baranowski

Field Summary

protected IMutablePeerTable	manager
protected IMetaData	metaData
protected IRouter	router
protected IStatistic	statistic

Constructor Summary

NetworkImpl(IStatisticManager statisticFactory, IMetaData metaData, IRouter router)

Method Summary

void	addNetworkReqListener(NetworkReqListener networkReqListener, ApplicationId... applicationId)
void	addNetworkReqListener(NetworkReqListener listener, Selector<Message,ApplicationId>... selectors)
Peer	addPeer(java.lang.String name, java.lang.String realm, boolean connecting)
Realm	addRealm(java.lang.String name, ApplicationId applicationId, LocalAction localAction, IAgentConfiguration agentConfiguration, boolean dynamic, long expirationTime)
Realm	addRealm(java.lang.String name, ApplicationId applicationId, LocalAction localAction, java.lang.String agentConfiguration, boolean dynamic, long expirationTime)
NetworkReqListener	getListener(IMessage message) Return NetworkListener instance for specified application-id
Statistic	getStatistic()
boolean	isWrapperFor(java.lang.Class<?> aClass)
void	removeNetworkReqListener(ApplicationId... applicationId)
void	removeNetworkReqListener(Selector<Message,ApplicationId>... selectors)
java.util.Collection<Realm>	remRealm(java.lang.String name)
void	setPeerManager(IMutablePeerTable manager) This method set peer manager for addPeer/remPeer methods
<T> T	unwrap(java.lang.Class<T> aClass)

Methods inherited from class java.lang.Object

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

Field Detail

manager

protected IMutablePeerTable manager

router

protected IRouter router

metaData

protected IMetaData metaData

statistic

protected IStatistic statistic

Constructor Detail

NetworkImpl

public NetworkImpl(IStatisticManager statisticFactory,
                   IMetaData metaData,
                   IRouter router)

Method Detail

addNetworkReqListener

public void addNetworkReqListener(NetworkReqListener networkReqListener,
                                  ApplicationId... applicationId)
                           throws ApplicationAlreadyUseException

Specified by:

addNetworkReqListener in interface Network

Throws:

ApplicationAlreadyUseException

addNetworkReqListener

public void addNetworkReqListener(NetworkReqListener listener,
                                  Selector<Message,ApplicationId>... selectors)

Specified by:

addNetworkReqListener in interface Network

removeNetworkReqListener

public void removeNetworkReqListener(ApplicationId... applicationId)

Specified by:

removeNetworkReqListener in interface Network

removeNetworkReqListener

public void removeNetworkReqListener(Selector<Message,ApplicationId>... selectors)

Specified by:

removeNetworkReqListener in interface Network

addPeer

public Peer addPeer(java.lang.String name,
                    java.lang.String realm,
                    boolean connecting)

isWrapperFor

public boolean isWrapperFor(java.lang.Class<?> aClass)
                     throws InternalException

Specified by:

isWrapperFor in interface Wrapper

Throws:

InternalException

unwrap

public <T> T unwrap(java.lang.Class<T> aClass)
         throws InternalException

Specified by:

unwrap in interface Wrapper

Throws:

InternalException

addRealm

public Realm addRealm(java.lang.String name,
                      ApplicationId applicationId,
                      LocalAction localAction,
                      java.lang.String agentConfiguration,
                      boolean dynamic,
                      long expirationTime)

addRealm

public Realm addRealm(java.lang.String name,
                      ApplicationId applicationId,
                      LocalAction localAction,
                      IAgentConfiguration agentConfiguration,
                      boolean dynamic,
                      long expirationTime)

remRealm

public java.util.Collection<Realm> remRealm(java.lang.String name)

getStatistic

public Statistic getStatistic()

Specified by:

getStatistic in interface Network

getListener

public NetworkReqListener getListener(IMessage message)

Description copied from interface: INetwork

Return NetworkListener instance for specified application-id

Specified by:

getListener in interface INetwork

Parameters:

message - message

Returns:

NetworkListener instance for specified selector

See Also:

NetworkReqListener

setPeerManager

public void setPeerManager(IMutablePeerTable manager)

Description copied from interface: INetwork

This method set peer manager for addPeer/remPeer methods

Specified by:

setPeerManager in interface INetwork

Parameters:

manager - PeerTable instance