Explanation

This interface functions as the connector used for attaching to the SDP server. A connector is generated as an SDPConnector type object.

A connector is used to attach to a query group's input or output stream that has been defined in the SDP server.

The openStreamInput or openStreamOutput method of the SDPConnector interface is used to connect to a stream. However, a single connector cannot connect to a stream with the same name more than once.

You generate a connector using the following process, depending on the data connection method between the SDP server and a custom adaptor that you use.

• Generating a connector that connects to the SDP server using an RMI connection
  Calling the connect method of the SDPConnectorFactory class generates a connector that attaches to the SDP server using an RMI connection.
  
• Generating a connector that connects to the SDP server using an in-process connection
  When the sdpstartinpro command is executed, a connector is generated that attaches to the SDP server using an in-process connection. This adaptor receives the generated SDPConnector type object as an execute method parameter from the StreamInprocessUP interface.
  

Field

None.

Constructor

None.

Method

The following table shows the SDPConnector interface method list.

Return value	Method name	Function
void	close()	Closes the connector.
boolean	isClosed()	Checks whether the connector is closed.
StreamInput	openStreamInput(String group_name,String stream_name)	Connects to the input stream that corresponds to the group name and stream name specified in the parameters. An SDPConnector type object cannot connect to a stream with the same name more than once.
StreamOutput	openStreamOutput(String group_name,String stream_name)	Connects to the output stream that corresponds to the group name and stream name specified in the parameters. An SDPConnector type object cannot connect to a stream with the same name more than once.

Notes

None.

Organization of this section

close() method

isClosed() method

openStreamInput(String group_name,String stream_name) method

openStreamOutput(String group_name,String stream_name) method