cgl.narada.node
Class ClientNode

java.lang.Object
  cgl.narada.node.ClientNode

All Implemented Interfaces:

NodeDebugFlags

public class ClientNode
extends Object
implements NodeDebugFlags

This is the client node for our class. This class is responsible for

• Publishing events
• Expressing interest in certain event - their subscription predicates
• Being able to roam in response to node failures and so on.

  Field Summary

  Fields inherited from interface cgl.narada.node.NodeDebugFlags

  BrokerNode_Debug, BrokerPropertiesReader_Debug, ClientNode_Debug, ServerNode_Debug

  Constructor Summary

  ClientNode()
  

  Method Summary

  void	connectTo(String hostName, int portNum, byte transport) Initiates a connection with the server that posseses the information contained within the request
  void	eventPropagationRequest(String server, String event, int minSize) This method is responsible for publishing an event to the system.
  void	gatherStats(int _pubRate, int _matchRate, int _messageSize)
  int[]	getMatchRates()
  int[]	getMessageSizes()
  int[]	getPublishRates()
  void	initializeLatencyArray(int size)
  void	initializeReportFile(String fileName)
  void	loopThroughMessageSizes(String reportFileName)
  static void	main(String[] args)
  void	nodeAddressRequest(String server) This method is reponsible for issuing a node address request to the server in question.
  void	persistentEventPropagationRequest(String server, String event, int minSize) This method is responsible for publishing a PERSISTENT event to the system.
  void	profilePropagationRequest(String server, String subscription) Propagates the interest in a subscription to the server in question.
  float	readPublishRate()
  void	setMatchRate(int matchRate)
  void	setPublishRate(int pRate)
  void	setRates(int pubRate, int numOfMessages, int messagesAtTime) This method sets the publish rate ...
  void	setUpNode(int portNum, byte transportType) This method serves as an intermediary between the transport layer and protocol layer and is responsible for setting up the server node.
  void	setUpNodeNew(Properties props, String transportType) This method serves as an intermediary between the transport layer and protocol layer and is responsible for setting up the server node.
  void	startTestingProcess(String serverName, int portNum)
  void	writeLatenciesToFile(long[] acceptedLatencies)
  void	writePublishRate(float publishRate)
  void	writeToReportFile(String reportLine)

  Methods inherited from class java.lang.Object

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

  Constructor Detail

  ClientNode

  public ClientNode()

  Method Detail

  setRates

  public void setRates(int pubRate,
                       int numOfMessages,
                       int messagesAtTime)

  This method sets the publish rate ... testing purposes only

  Parameters:

  pubRate - The publish rate

  setPublishRate

  public void setPublishRate(int pRate)

  setMatchRate

  public void setMatchRate(int matchRate)

  getMessageSizes

  public int[] getMessageSizes()

  getPublishRates

  public int[] getPublishRates()

  getMatchRates

  public int[] getMatchRates()

  setUpNode

  public void setUpNode(int portNum,
                        byte transportType)

  This method serves as an intermediary between the transport layer and protocol layer and is responsible for setting up the server node.

  setUpNodeNew

  public void setUpNodeNew(Properties props,
                           String transportType)

  This method serves as an intermediary between the transport layer and protocol layer and is responsible for setting up the server node.

  connectTo

  public void connectTo(String hostName,
                        int portNum,
                        byte transport)

  Initiates a connection with the server that posseses the information contained within the request

  nodeAddressRequest

  public void nodeAddressRequest(String server)

  This method is reponsible for issuing a node address request to the server in question.

  Parameters:

  server - The server to which this request is being issued.

  profilePropagationRequest

  public void profilePropagationRequest(String server,
                                        String subscription)

  Propagates the interest in a subscription to the server in question. This method cannot be issued unitil the client has been assigned a logical address by the system.

  Parameters:

  server - The server to which this client is attached.

  subscription - The subscription predicate for the client

  eventPropagationRequest

  public void eventPropagationRequest(String server,
                                      String event,
                                      int minSize)

  This method is responsible for publishing an event to the system.

  Parameters:

  server - The server to which this request is being issued.

  event - The event that is being published

  minSize - Minimum Size of the event being published.

  persistentEventPropagationRequest

  public void persistentEventPropagationRequest(String server,
                                                String event,
                                                int minSize)

  This method is responsible for publishing a PERSISTENT event to the system.

  Parameters:

  server - The server to which this request is being issued.

  event - The event that is being published

  minSize - Minimum Size of the event being published.

  gatherStats

  public void gatherStats(int _pubRate,
                          int _matchRate,
                          int _messageSize)

  initializeLatencyArray

  public void initializeLatencyArray(int size)

  loopThroughMessageSizes

  public void loopThroughMessageSizes(String reportFileName)

  startTestingProcess

  public void startTestingProcess(String serverName,
                                  int portNum)

  initializeReportFile

  public void initializeReportFile(String fileName)

  writeToReportFile

  public void writeToReportFile(String reportLine)

  writeLatenciesToFile

  public void writeLatenciesToFile(long[] acceptedLatencies)

  writePublishRate

  public void writePublishRate(float publishRate)

  readPublishRate

  public float readPublishRate()

  main

  public static void main(String[] args)