Skip navigation links

com.bea.wcp.diameter
Class Node

java.lang.Object
com.bea.wcp.diameter.Node

public final class Node

extends Object

Diameter Node implementation. Support both client and server-based Diameter applications as well as relay applications.

Field Summary

MessageDebugBean

msgDebugBean

Constructor Summary

Node(Provider provider)

Node(Provider provider, ConfigurationBean config)

Node(Provider provider, String host, String realm, InetAddress address, int port)

Node(Provider provider, String host, String realm, InetAddress address, int port, boolean tls)

Method Summary

Connection	connect(Peer peer)
static Node	createNode(File configFile) Creates a new Diameter Node instance for the specified configuration.
void	deliverToApplication(Message msg) Called by provider to deliver message to application with specified id.
boolean	deliverToSession(Message msg, Session session) Deliver message to specified session.
void	dispatch(Message msg) Dispatch message to session or application.
void	dispatchRelay(Message msg) Dispatch message to relay application.
void	dispatchThreadAnswer(Request req, Answer ans)
void	execute(Runnable task)
Application	getApplication(ApplicationId id) Returns the application for the specified application identifier.
Application	getApplication(int idNum) Returns the application for the specified application id number.
AppManager	getAppManager()
Capabilities	getCapabilities()
ConfigurationBean	getConfiguration() Returns the ConfigurationBean for the node
String	getHost() Returns the origin host for the node
static Node	getInstance() Returns the Node instance to use when deserializing session objects.
InetAddress	getListenAddress() Returns the Node listen address
Peer	getPeer(String hostId)
PeerTable	getPeerTable()
Provider	getProvider()
String	getRealm() Returns the origin realm for the node
RouteTable	getRouteTable()
SocketAddress	getSocketAddress()
int	getStateId()
Version	getVersion()
boolean	isIncludeOriginStateId()
boolean	isLocalAnswer(Answer ans) Returns true if answer should be processed locally (not relayed).
boolean	isLocalRequest(Request req) Check if request should be processed locally (RFC 3588 6.1.4).
boolean	isMsgDebug()
boolean	isMsgDebugLogging()
boolean	isRunning() Returns true if the Node is currently running.
boolean	isSctpEnabled()
boolean	isTlsEnabled()
static void	main(String[] args) Starts the Diameter Node for the specified command line arguments.
void	setIncludeOriginStateId(boolean enabled)
static void	setInstance(Node node) Sets the Node instance that will be used for deserialization of persistent session objects.
void	setMsgDebug(boolean enabled)
void	start() Starts the Diameter Node instance.
void	stop() Stops the Diameter Node instance.

Methods inherited from class java.lang.Object

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

Field Detail

msgDebugBean

public MessageDebugBean msgDebugBean

Constructor Detail

Node

public Node(Provider provider,
            ConfigurationBean config)
     throws DiameterException

Throws:

DiameterException

Node

public Node(Provider provider,
            String host,
            String realm,
            InetAddress address,
            int port)

Node

public Node(Provider provider,
            String host,
            String realm,
            InetAddress address,
            int port,
            boolean tls)

Node

public Node(Provider provider)

Method Detail

setInstance

public static void setInstance(Node node)

Sets the Node instance that will be used for deserialization of persistent session objects.

getInstance

public static Node getInstance()

Returns the Node instance to use when deserializing session objects.

createNode

public static Node createNode(File configFile)
                       throws IOException,
                              DiameterException

Creates a new Diameter Node instance for the specified configuration. Used to start a Diameter node in standalone mode for testing.

Parameters:

configFile - the diameter.xml configuration file

Returns:

the Diameter Node instance

Throws:

IOException - if an I/O error occurred reading the configuration

DiameterException - if the Node could not be initialized

getListenAddress

public InetAddress getListenAddress()

Returns the Node listen address

start

public void start()
           throws IOException

Starts the Diameter Node instance.

Throws:

IOException - if an I/O error occurred while starting

stop

public void stop()
          throws IOException

Stops the Diameter Node instance.

Throws:

IOException - if an I/O error occurred while stopping the node

isRunning

public boolean isRunning()

Returns true if the Node is currently running.

getHost

public String getHost()

Returns the origin host for the node

getRealm

public String getRealm()

Returns the origin realm for the node

getVersion

public Version getVersion()

getConfiguration

public ConfigurationBean getConfiguration()

Returns the ConfigurationBean for the node

getStateId

public int getStateId()

getCapabilities

public Capabilities getCapabilities()

getSocketAddress

public SocketAddress getSocketAddress()

getProvider

public Provider getProvider()

getPeerTable

public PeerTable getPeerTable()

getAppManager

public AppManager getAppManager()

getRouteTable

public RouteTable getRouteTable()

getPeer

public Peer getPeer(String hostId)

isTlsEnabled

public boolean isTlsEnabled()

isSctpEnabled

public boolean isSctpEnabled()

isIncludeOriginStateId

public boolean isIncludeOriginStateId()

setIncludeOriginStateId

public void setIncludeOriginStateId(boolean enabled)

getApplication

public Application getApplication(int idNum)

Returns the application for the specified application id number.

Parameters:

idNum - the application's numeric identifier

Returns:

the corresponding Application, or null if not found

getApplication

public Application getApplication(ApplicationId id)

Returns the application for the specified application identifier.

Parameters:

id - the ApplicationId for the application

Returns:

the corresponding Application, or null if not found

isLocalRequest

public boolean isLocalRequest(Request req)

Check if request should be processed locally (RFC 3588 6.1.4).

isLocalAnswer

public boolean isLocalAnswer(Answer ans)

Returns true if answer should be processed locally (not relayed). 6.2.2 If the last Proxy-Info AVP in the message is targeted to the local Diameter server, the AVP MUST be removed before the answer is forwarded.

dispatch

public void dispatch(Message msg)
              throws IOException

Dispatch message to session or application.

Parameters:

msg - the request or answer message to dispatch

Throws:

IOException - if an I/O error occurred during dispatch

dispatchThreadAnswer

public void dispatchThreadAnswer(Request req,
                                 Answer ans)

dispatchRelay

public void dispatchRelay(Message msg)

Dispatch message to relay application.

deliverToSession

public boolean deliverToSession(Message msg,
                                Session session)

Deliver message to specified session. Used during message dispatch, and by server applications to deliver requests to newly created sessions.

Parameters:

msg - the message to be delivered

session - the session to receive the message

deliverToApplication

public void deliverToApplication(Message msg)

Called by provider to deliver message to application with specified id.

connect

public Connection connect(Peer peer)
                   throws IOException

Throws:

IOException

isMsgDebug

public boolean isMsgDebug()

setMsgDebug

public void setMsgDebug(boolean enabled)

isMsgDebugLogging

public boolean isMsgDebugLogging()

execute

public void execute(Runnable task)

main

public static void main(String[] args)
                 throws Exception

Starts the Diameter Node for the specified command line arguments.

Parameters:

args - Diameter Node command line arguments

Throws:

Exception - if an error occurs while starting the node

Skip navigation links