cgl.hpsearch.common.endpoint
Class NBEventEndPoint

java.lang.Object
  cgl.hpsearch.common.endpoint.EndPoint
      cgl.hpsearch.common.endpoint.NBEventEndPoint

All Implemented Interfaces:

NBEventListener, SystemConstants

public class NBEventEndPoint

extends EndPoint

implements NBEventListener, SystemConstants

An EndPoint Listener that listens on a specified topic for events

Author:

Harshawardhan Gadgil (hgadgil@grids.ucs.indiana.edu)

Field Summary

Fields inherited from interface cgl.hpsearch.common.SystemConstants

ABANDON_HANDLER, ABANDONED, BROKER_HOST, BROKER_PORT, BUF_SIZE, EOT, EXCEPTION, FAILURE, FILESEPARTOR, FLOW_LOGGING_MANAGER, FLOW_MANAGER, HPSEARCH_CONFIG, HPSEARCH_HOME, HPSEARCH_SHELL, HPSEARCH_WS, MARKER, NB_HOME, NB_PERFORMANCE_DATA_TOPIC, OS_TYPE, OS_UNIX, OS_WIN, PORT, PROTOCOL, READY, RESUME, RUNNING, SCRIPT_ARGS, SCRIPT_PATH, SHELLWS_PORT, START_HANDLER, STREAM_MARKER_DATA, STREAM_MARKER_EOF, STX, SUCCESS, SUSPEND, TASK_DEFINED, TASK_SCHEDULER_ENGINE, TASKSCHEDULER_AUTO_CONNECT_COMM_LINK, TASKSCHEDULER_ENGINE_COMM_LINK, THREAD_SLEEP_INTERVAL, UNKNOWN, WAITING, WSCONTEXT_RESULT_BIN, WSCONTEXT_SERVICE

Constructor Summary

NBEventEndPoint(String endpointSpec, EndPointListener client)

Method Summary

void	close()
void	initEndPoint(String endPointspec) Connects to the specified Broker and subscribes to the stream on specified topic
void	onEvent(NBEvent nbEvent)

Methods inherited from class cgl.hpsearch.common.endpoint.EndPoint

eof, processEvent

Methods inherited from class java.lang.Object

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

Constructor Detail

NBEventEndPoint

public NBEventEndPoint(String endpointSpec,
                       EndPointListener client)

Parameters:

endpointSpec -

Method Detail

initEndPoint

public void initEndPoint(String endPointspec)

Connects to the specified Broker and subscribes to the stream on specified topic

Specified by:

initEndPoint in class EndPoint

Parameters:

endPointspec - - The topic to subscribe to

onEvent

public void onEvent(NBEvent nbEvent)

Specified by:

onEvent in interface NBEventListener

close

public void close()

Specified by:

close in class EndPoint