edu.berkeley.guir.ptk.server
Class PDiscovery

java.lang.Object
  edu.berkeley.guir.ptk.PTK
      edu.berkeley.guir.ptk.server.PComm
          edu.berkeley.guir.ptk.server.PServer
              edu.berkeley.guir.ptk.server.PDiscovery

All Implemented Interfaces:

java.lang.Cloneable, java.lang.Runnable

public class PDiscovery

extends PServer

When running a distributed PTK application, you must execute this class first; once it is running, it will listen for inputs to register and outputs to subscribe, and it will route events between them.

Field Summary

(package private) PDiscoveryHistory	history
static java.lang.String	ID
(package private) java.util.Hashtable	inputs
(package private) java.util.Hashtable	subscribers

Fields inherited from class edu.berkeley.guir.ptk.server.PComm

id, local_ip, local_port, server, server_ip, server_port

Fields inherited from class edu.berkeley.guir.ptk.PTK

debug, MAX_DEBUG, MED_DEBUG, MIN_DEBUG, NO_DEBUG

Constructor Summary

PDiscovery(java.lang.String localIp, int localPort)

Method Summary

void	getDispatch(PMessageDispatch pmd)
PMessageHistoryResponse	getHistory(PMessageHistoryRequest pmhr)
void	getRegister(java.lang.String clientIp, java.lang.String clientId, Metadata md)
void	getSubscribe(PMessageSubscribe pms)
void	getUnregister(java.lang.String clientIp, java.lang.String clientId)
void	getUnsubscribe(PMessageUnsubscribe pms)
static void	main(java.lang.String[] argv)
PMessage	serverHandleMessage(PMessage pm)

Methods inherited from class edu.berkeley.guir.ptk.server.PComm

decodeMessage, getConnection, handleIncomingMessage, run, sendMessage, sendMessage, start, stopServer

Methods inherited from class edu.berkeley.guir.ptk.PTK

getMAX, getMED, getMIN, getNO, printDebug, printDebug, printError

Methods inherited from class java.lang.Object

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

Field Detail

ID

public static final java.lang.String ID

See Also:

Constant Field Values

inputs

java.util.Hashtable inputs

subscribers

java.util.Hashtable subscribers

history

PDiscoveryHistory history

Constructor Detail

PDiscovery

public PDiscovery(java.lang.String localIp,
                  int localPort)

Method Detail

getRegister

public void getRegister(java.lang.String clientIp,
                        java.lang.String clientId,
                        Metadata md)

getUnregister

public void getUnregister(java.lang.String clientIp,
                          java.lang.String clientId)

getDispatch

public void getDispatch(PMessageDispatch pmd)

getSubscribe

public void getSubscribe(PMessageSubscribe pms)

getUnsubscribe

public void getUnsubscribe(PMessageUnsubscribe pms)

getHistory

public PMessageHistoryResponse getHistory(PMessageHistoryRequest pmhr)

serverHandleMessage

public PMessage serverHandleMessage(PMessage pm)

Overrides:

serverHandleMessage in class PComm

main

public static void main(java.lang.String[] argv)