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 );
-
SddReceiver(String, int)
- public constructor
-
addContentListener(ContentListener)
- method to register the content callback
-
addDataListener(DataListener)
- method to register the data callback
-
addExtractorListener(ExtractorListener)
- method to register the extractor callback
-
addSchemaListener(SchemaListener)
- method to register the schema callback
-
addSerialNumListener(SerialNumListener)
- method to register the serialnum callback
-
contentReceived(ContentEvent)
- example content callback
-
dataReceived(DataEvent)
- example data callback
-
disableParsing()
- method to disable SQL parsing of schema and contents
-
disableParsingFailExit()
- method to disable parsing exits
-
disableSql()
- method to unset the SQL flag
-
enableParsing()
- method to enable SQL parsing of schema and contents
-
enableParsingFailExit()
- method to enable parsing exits
-
enableSql()
- method to set the SQL flag
-
exit()
- exit method
-
extractorReceived(ExtractorEvent)
- example extractor callback
-
getItsFrameReceiver()
- method to get the ItsFrameReceiver status
-
getStatus()
- method to get the SddReceiver status
-
isParsingEnabled()
- function to get the parsing enabled flag
-
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.
-
isSqlEnabled()
- function to get the SQL flag setting
-
itsFrameReceived(ItsFrame)
- callback for ItsFrames, invoked from ItsFrameReceiver when a new ItsFrame is
received
-
main(String[])
- test method
-
removeContentListener(ContentListener)
- method to remove a content listener
-
removeDataListener(DataListener)
- method to remove a data listener
-
removeExtractorListener(ExtractorListener)
- method to remove a extractor listener
-
removeSchemaListener(SchemaListener)
- method to remove a schema listener
-
removeSerialNumListener(SerialNumListener)
- method to remove a serial number listener
-
run()
- thread run method, basically waits for data, then calls checkListenerVec()
-
schemaReceived(SchemaEvent)
- example schema callback
-
serialNumReceived(SerialNumEvent)
- example serial number callback
SddReceiver
public SddReceiver(String serverName,
int serverPort) throws UnknownHostException
- public constructor
- Parameters:
- host - contains the servers hostname
- port - contains the servers port number
itsFrameReceived
public void itsFrameReceived(ItsFrame frame)
- callback for ItsFrames, invoked from ItsFrameReceiver when a new ItsFrame is
received
- Parameters:
- frame - contains the servers hostname
run
public void run()
- thread run method, basically waits for data, then calls checkListenerVec()
- Overrides:
- run in class Thread
exit
public void exit()
- exit method
- Overrides:
- exit in class Thread
isSqlEnabled
public boolean isSqlEnabled()
- function to get the SQL flag setting
- Returns:
- s boolean true is SQL output is enabled
enableSql
public void enableSql()
- method to set the SQL flag
disableSql
public void disableSql()
- method to unset the SQL flag
addSchemaListener
public synchronized void addSchemaListener(SchemaListener schemaListener)
- method to register the schema callback
- Parameters:
- schemaListener - contains object containing schema callback
addContentListener
public synchronized void addContentListener(ContentListener contentListener)
- method to register the content callback
- Parameters:
- contentListener - contains object containing content callback
addDataListener
public synchronized void addDataListener(DataListener dataListener)
- method to register the data callback
- Parameters:
- dataListener - contains object containing data callback
addSerialNumListener
public synchronized void addSerialNumListener(SerialNumListener serialNumListener)
- method to register the serialnum callback
- Parameters:
- serialnumListener - contains object containing serialnum callback
addExtractorListener
public synchronized void addExtractorListener(ExtractorListener extractorListener)
- method to register the extractor callback
- Parameters:
- extractorListener - contains object containing extractor callback
removeSchemaListener
public void removeSchemaListener(SchemaListener schemaListener)
- method to remove a schema listener
- Parameters:
- schemaListener - listener to remove from the callback
removeContentListener
public void removeContentListener(ContentListener contentListener)
- method to remove a content listener
- Parameters:
- contentListener - listener to remove from the callback
removeDataListener
public void removeDataListener(DataListener dataListener)
- method to remove a data listener
- Parameters:
- dataListener - listener to remove from the callback
removeSerialNumListener
public void removeSerialNumListener(SerialNumListener serialNumListener)
- method to remove a serial number listener
- Parameters:
- serialNumListener - listener to remove from the callback
removeExtractorListener
public void removeExtractorListener(ExtractorListener extractorListener)
- method to remove a extractor listener
- Parameters:
- extractorListener - listener to remove from the callback
schemaReceived
public void schemaReceived(SchemaEvent event)
- example schema callback
- Parameters:
- event - contains the schema event
- See Also:
- SchemaEvent
contentReceived
public void contentReceived(ContentEvent event)
- example content callback
- Parameters:
- event - contains the content event
- See Also:
- ContentEvent
dataReceived
public void dataReceived(DataEvent event)
- example data callback
- Parameters:
- event - contains the data event
- See Also:
- DataEvent
serialNumReceived
public void serialNumReceived(SerialNumEvent event)
- example serial number callback
- Parameters:
- event - contains the serial number event
- See Also:
- SerialNumEvent
extractorReceived
public void extractorReceived(ExtractorEvent event)
- example extractor callback
- Parameters:
- event - contains the extractor event
- See Also:
- ExtractorEvent
getStatus
public SddReceiverStatus getStatus()
- method to get the SddReceiver status
- Returns:
- s SddReceiverStatus contains the receivers status
- See Also:
- SddReceiverStatus
getItsFrameReceiver
public ItsFrameReceiver getItsFrameReceiver()
- method to get the ItsFrameReceiver status
- Returns:
- s ItsFrameReceiverStatus contains the ItsFrame layer receiver status
- See Also:
- ItsFrameReceiverStatus
isParsingEnabled
public boolean isParsingEnabled()
- function to get the parsing enabled flag
- Returns:
- s boolean true if SQL parsing is enabled
disableParsing
public void disableParsing()
- method to disable SQL parsing of schema and contents
enableParsing
public void enableParsing()
- method to enable SQL parsing of schema and contents
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
disableParsingFailExit
public void disableParsingFailExit()
- method to disable parsing exits
enableParsingFailExit
public void enableParsingFailExit()
- method to enable parsing exits
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