Explanation
For a custom adaptor to connect to the SDP server using an in-process connection, you must create a class in which the StreamInprocessUP interface is implemented.
The StreamInprocessUP interface provides the execute method and the stop method.
For the execute method, specify the main process (which is equivalent to the main method of the custom adaptor). For the stop method, specify the termination process for the custom adaptor.
When the sdpstartinpro command is executed to start an in-process connection custom adaptor, the SDP server loads a class in which the StreamInprocessUP interface is implemented and generates a thread (custom adaptor execution thread) in which the execute method runs. The execute method is called from this thread. Specify the implemented class name to be loaded by the SDP server and the path name for the jar file that stores the implemented class in the property file user_app.in-process-connection-custom-adaptor-name.properties. For details about property files, see the manual uCosminexus Stream Data Platform - Application Framework Setup and Operation Guide.
The stop method is called from an SDP server thread when the sdpstopinpro command is executed to stop the in-process connection custom adaptor.
Method
The following table shows the StreamInprocessUP interface method list.
Return value | Method name | Function |
---|---|---|
void | execute(SDPConnector con) | Defines the custom adaptor's main process. This method is called by the custom adaptor execution thread generated by the SDP server when the sdpstartinpro command is executed. |
void | stop() | Defines the custom adaptor's termination process. This method is called by an SDP server thread when the sdpstopinpro command is executed. |
Notes