org.jdiameter.server.impl
Class PeerImpl

java.lang.Object
  org.jdiameter.client.impl.controller.PeerImpl
      org.jdiameter.server.impl.PeerImpl

All Implemented Interfaces:

java.lang.Comparable<org.jdiameter.api.Peer>, org.jdiameter.api.Peer, IPeer

public class PeerImpl
extends PeerImpl
implements IPeer

Nested Class Summary

static class	PeerImpl.Entry
protected class	PeerImpl.LocalActionConext

Nested classes/interfaces inherited from class org.jdiameter.client.impl.controller.PeerImpl

PeerImpl.ActionContext

Field Summary

protected ISessionFactory	factory
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,PeerImpl.Entry>	incConnections
protected boolean	isAttemptConnection
protected boolean	isDuplicateProtection
protected boolean	isElection
protected INetwork	network
protected IOverloadManager	ovrManager
protected java.util.Set<org.jdiameter.api.URI>	predefinedPeerTable
protected IStatisticRecord	reqStat
protected IStatisticRecord	respStat
protected IStatistic	statistic

Fields inherited from class org.jdiameter.client.impl.controller.PeerImpl

addresses, commonApplications, conn, connListener, firmWare, fsm, fsmListener, hopByHopId, INT_COMMON_APP_ID, logger, metaData, parser, peerRequests, productName, rating, realmName, router, slc, stopping, table, uid, uri, useUriAsFQDN, vendorID

Constructor Summary

PeerImpl(MutablePeerTableImpl mgr, int rating, org.jdiameter.api.URI remotePeer, IMetaData metaData, org.jdiameter.api.Configuration config, org.jdiameter.api.Configuration peerConfig, ISessionFactory sessionFactory, IFsmFactory fsmFactory, ITransportLayerFactory trFactory, IMessageParser parser, INetwork nWork, IOverloadManager oManager, boolean attCnn, IConnection connection)
Create instance of class

Method Summary

void	addIncomingConnection(IConnection conn)
IConnection	getConnection()
IContext	getContext()
org.jdiameter.api.Statistic	getStatistic()
boolean	isAttemptConnection()
void	notifyOvrManager(IOverloadManager ovrManager)
protected void	preProcessRequest(IMessage message)
void	setElection(boolean isElection)
java.lang.String	toString()

Methods inherited from class org.jdiameter.client.impl.controller.PeerImpl

addConnectionListener, addMessage, addPeerStateListener, addStateChangeListener, compareTo, connect, disconnect, fillIPAddressTable, getCommonApplicationIds, getCommonApplications, getFirmware, getHopByHopIdentifier, getIPAddresses, getProductName, getRaiting, getRealmName, getState, getUri, getVendorId, hasValidConnection, remAllMessage, remConnectionListener, remMessage, removePeerStateListener, remStateChangeListener, sendMessage, setRealm

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jdiameter.client.api.controller.IPeer

addConnectionListener, addMessage, addStateChangeListener, getHopByHopIdentifier, getRaiting, hasValidConnection, remAllMessage, remConnectionListener, remMessage, remStateChangeListener, sendMessage, setRealm

Methods inherited from interface org.jdiameter.api.Peer

addPeerStateListener, connect, disconnect, getCommonApplications, getFirmware, getIPAddresses, getProductName, getRealmName, getState, getUri, getVendorId, removePeerStateListener

Field Detail

predefinedPeerTable

protected java.util.Set<org.jdiameter.api.URI> predefinedPeerTable

network

protected INetwork network

ovrManager

protected IOverloadManager ovrManager

factory

protected ISessionFactory factory

isDuplicateProtection

protected boolean isDuplicateProtection

isAttemptConnection

protected boolean isAttemptConnection

isElection

protected boolean isElection

incConnections

protected java.util.concurrent.ConcurrentHashMap<java.lang.String,PeerImpl.Entry> incConnections

reqStat

protected IStatisticRecord reqStat

respStat

protected IStatisticRecord respStat

statistic

protected IStatistic statistic

Constructor Detail

PeerImpl

public PeerImpl(MutablePeerTableImpl mgr,
                int rating,
                org.jdiameter.api.URI remotePeer,
                IMetaData metaData,
                org.jdiameter.api.Configuration config,
                org.jdiameter.api.Configuration peerConfig,
                ISessionFactory sessionFactory,
                IFsmFactory fsmFactory,
                ITransportLayerFactory trFactory,
                IMessageParser parser,
                INetwork nWork,
                IOverloadManager oManager,
                boolean attCnn,
                IConnection connection)
         throws org.jdiameter.api.InternalException,
                TransportException

Create instance of class

Throws:

org.jdiameter.api.InternalException

TransportException

Method Detail

getStatistic

public org.jdiameter.api.Statistic getStatistic()

preProcessRequest

protected void preProcessRequest(IMessage message)

Overrides:

preProcessRequest in class PeerImpl

isAttemptConnection

public boolean isAttemptConnection()

getContext

public IContext getContext()

Overrides:

getContext in class PeerImpl

getConnection

public IConnection getConnection()

addIncomingConnection

public void addIncomingConnection(IConnection conn)

setElection

public void setElection(boolean isElection)

notifyOvrManager

public void notifyOvrManager(IOverloadManager ovrManager)

toString

public java.lang.String toString()

Overrides:

toString in class PeerImpl