cgl.narada.aggregator
Class AggregationNode

java.lang.Object
  extended by 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)


For comments and suggestions please send e-mail to The NaradaBrokering Project