All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class its.backbone.sdd.SddReceiver

java.lang.Object
   |
   +----java.lang.Thread
           |
           +----its.backbone.sdd.SddReceiver

public class SddReceiver
extends Thread
implements ItsFrameListener, SchemaListener, ContentListener, DataListener, SerialNumListener, ExtractorListener
Class to receive SDD streams, The class uses the ItsFrameReceiver to establish a TCP connection to a server and receiver ItsFrames. These frames are assumed to contain SDD frame which are decoded within this class. For example:
	try {
		// construct a receiver object with host and port number
		sddReceiver = new SddReceiver( host, port );
	} catch ( java.net.UnknownHostException e )
	{
		System.err.println( "unknown host: " + host );
		System.exit(1);
	}
	// disable parsing and SQL generation
	sddReceiver.disableSql();
	sddReceiver.disableParsing();
	// register callbacks
	sddReceiver.addSchemaListener( this );
	sddReceiver.addContentListener( this );
	sddReceiver.addDataListener( this );
	sddReceiver.addSerialNumListener( this );
	sddReceiver.addExtractorListener( this );
 


Constructor Index

 o SddReceiver(String, int)
public constructor

Method Index

 o addContentListener(ContentListener)
method to register the content callback
 o addDataListener(DataListener)
method to register the data callback
 o addExtractorListener(ExtractorListener)
method to register the extractor callback
 o addSchemaListener(SchemaListener)
method to register the schema callback
 o addSerialNumListener(SerialNumListener)
method to register the serialnum callback
 o contentReceived(ContentEvent)
example content callback
 o dataReceived(DataEvent)
example data callback
 o disableParsing()
method to disable SQL parsing of schema and contents
 o disableParsingFailExit()
method to disable parsing exits
 o disableSql()
method to unset the SQL flag
 o enableParsing()
method to enable SQL parsing of schema and contents
 o enableParsingFailExit()
method to enable parsing exits
 o enableSql()
method to set the SQL flag
 o exit()
exit method
 o extractorReceived(ExtractorEvent)
example extractor callback
 o getItsFrameReceiver()
method to get the ItsFrameReceiver status
 o getStatus()
method to get the SddReceiver status
 o isParsingEnabled()
function to get the parsing enabled flag
 o isParsingFailExitEnabled()
function to get the state of the parsing error(fail) exit flag - If this flag is set, a parsing error with force an System.exit() call.
 o isSqlEnabled()
function to get the SQL flag setting
 o itsFrameReceived(ItsFrame)
callback for ItsFrames, invoked from ItsFrameReceiver when a new ItsFrame is received
 o main(String[])
test method
 o removeContentListener(ContentListener)
method to remove a content listener
 o removeDataListener(DataListener)
method to remove a data listener
 o removeExtractorListener(ExtractorListener)
method to remove a extractor listener
 o removeSchemaListener(SchemaListener)
method to remove a schema listener
 o removeSerialNumListener(SerialNumListener)
method to remove a serial number listener
 o run()
thread run method, basically waits for data, then calls checkListenerVec()
 o schemaReceived(SchemaEvent)
example schema callback
 o serialNumReceived(SerialNumEvent)
example serial number callback

Constructors

 o SddReceiver
 public SddReceiver(String serverName,
                    int serverPort) throws UnknownHostException
public constructor

Parameters:
host - contains the servers hostname
port - contains the servers port number

Methods

 o itsFrameReceived
 public void itsFrameReceived(ItsFrame frame)
callback for ItsFrames, invoked from ItsFrameReceiver when a new ItsFrame is received

Parameters:
frame - contains the servers hostname
 o run
 public void run()
thread run method, basically waits for data, then calls checkListenerVec()

Overrides:
run in class Thread
 o exit
 public void exit()
exit method

Overrides:
exit in class Thread
 o isSqlEnabled
 public boolean isSqlEnabled()
function to get the SQL flag setting

Returns:
s boolean true is SQL output is enabled
 o enableSql
 public void enableSql()
method to set the SQL flag

 o disableSql
 public void disableSql()
method to unset the SQL flag

 o addSchemaListener
 public synchronized void addSchemaListener(SchemaListener schemaListener)
method to register the schema callback

Parameters:
schemaListener - contains object containing schema callback
 o addContentListener
 public synchronized void addContentListener(ContentListener contentListener)
method to register the content callback

Parameters:
contentListener - contains object containing content callback
 o addDataListener
 public synchronized void addDataListener(DataListener dataListener)
method to register the data callback

Parameters:
dataListener - contains object containing data callback
 o addSerialNumListener
 public synchronized void addSerialNumListener(SerialNumListener serialNumListener)
method to register the serialnum callback

Parameters:
serialnumListener - contains object containing serialnum callback
 o addExtractorListener
 public synchronized void addExtractorListener(ExtractorListener extractorListener)
method to register the extractor callback

Parameters:
extractorListener - contains object containing extractor callback
 o removeSchemaListener
 public void removeSchemaListener(SchemaListener schemaListener)
method to remove a schema listener

Parameters:
schemaListener - listener to remove from the callback
 o removeContentListener
 public void removeContentListener(ContentListener contentListener)
method to remove a content listener

Parameters:
contentListener - listener to remove from the callback
 o removeDataListener
 public void removeDataListener(DataListener dataListener)
method to remove a data listener

Parameters:
dataListener - listener to remove from the callback
 o removeSerialNumListener
 public void removeSerialNumListener(SerialNumListener serialNumListener)
method to remove a serial number listener

Parameters:
serialNumListener - listener to remove from the callback
 o removeExtractorListener
 public void removeExtractorListener(ExtractorListener extractorListener)
method to remove a extractor listener

Parameters:
extractorListener - listener to remove from the callback
 o schemaReceived
 public void schemaReceived(SchemaEvent event)
example schema callback

Parameters:
event - contains the schema event
See Also:
SchemaEvent
 o contentReceived
 public void contentReceived(ContentEvent event)
example content callback

Parameters:
event - contains the content event
See Also:
ContentEvent
 o dataReceived
 public void dataReceived(DataEvent event)
example data callback

Parameters:
event - contains the data event
See Also:
DataEvent
 o serialNumReceived
 public void serialNumReceived(SerialNumEvent event)
example serial number callback

Parameters:
event - contains the serial number event
See Also:
SerialNumEvent
 o extractorReceived
 public void extractorReceived(ExtractorEvent event)
example extractor callback

Parameters:
event - contains the extractor event
See Also:
ExtractorEvent
 o getStatus
 public SddReceiverStatus getStatus()
method to get the SddReceiver status

Returns:
s SddReceiverStatus contains the receivers status
See Also:
SddReceiverStatus
 o getItsFrameReceiver
 public ItsFrameReceiver getItsFrameReceiver()
method to get the ItsFrameReceiver status

Returns:
s ItsFrameReceiverStatus contains the ItsFrame layer receiver status
See Also:
ItsFrameReceiverStatus
 o isParsingEnabled
 public boolean isParsingEnabled()
function to get the parsing enabled flag

Returns:
s boolean true if SQL parsing is enabled
 o disableParsing
 public void disableParsing()
method to disable SQL parsing of schema and contents

 o enableParsing
 public void enableParsing()
method to enable SQL parsing of schema and contents

 o isParsingFailExitEnabled
 public boolean isParsingFailExitEnabled()
function to get the state of the parsing error(fail) exit flag - If this flag is set, a parsing error with force an System.exit() call.

Returns:
s boolean true if exit is enabled during a parsing error
 o disableParsingFailExit
 public void disableParsingFailExit()
method to disable parsing exits

 o enableParsingFailExit
 public void enableParsingFailExit()
method to enable parsing exits

 o main
 public static void main(String args[]) throws Exception
test method

Parameters:
args - command line parameters
Throws: Exception
exception

All Packages  Class Hierarchy  This Package  Previous  Next  Index