cgl.narada.aggregator
Class AggregationNode

java.lang.Object
  cgl.narada.aggregator.AggregationNode

All Implemented Interfaces:

InterchangeConstants, Handler

public class AggregationNode
extends Object
implements Handler, InterchangeConstants

This is an example which demonstrates using the transport interfaces in Narada. This class has presently been written for TCP communications. Subsequent versions of this class would include support for other transport types supported in NaradaBrokering.

Field Summary

Fields inherited from interface cgl.narada.aggregator.InterchangeConstants

DEREGISTER_NOTIFIER, INFO_POST_FROM_NOTIFIER, INFO_REQUEST_FROM_AGGREGATOR, INFO_RESPONSE_FROM_NOTIFIER, REGISTER_NOTIFIER

Constructor Summary

AggregationNode()

Method Summary

void	checkStatus()
String	createLinkTo(Properties props, String linkType)
void	handleData(byte[] data, String sender)
boolean	isClient() This method indicates that the node in question is a client
void	loadCommunicationsOfType(Properties commProps, String commType)
static void	main(String[] args)
void	processXML(String xml)
void	requestInfoFromNotifiers()
void	sendDataTo(byte[] data, String node)
void	writeAdminXML(String xmlmetrics)
void	writeHtml(String[] values)
void	writeUserXML(String xmlmetrics)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregationNode

public AggregationNode()

Method Detail

loadCommunicationsOfType

public void loadCommunicationsOfType(Properties commProps,
                                     String commType)

createLinkTo

public String createLinkTo(Properties props,
                           String linkType)

sendDataTo

public void sendDataTo(byte[] data,
                       String node)
                throws TransportException

Throws:

TransportException

isClient

public boolean isClient()

This method indicates that the node in question is a client

Specified by:

isClient in interface Handler

requestInfoFromNotifiers

public void requestInfoFromNotifiers()

handleData

public void handleData(byte[] data,
                       String sender)

Specified by:

handleData in interface Handler

checkStatus

public void checkStatus()

processXML

public void processXML(String xml)

writeAdminXML

public void writeAdminXML(String xmlmetrics)

writeUserXML

public void writeUserXML(String xmlmetrics)

writeHtml

public void writeHtml(String[] values)

main

public static void main(String[] args)