Class CasObjectNetworkCasProcessorImpl

  • All Implemented Interfaces:
    CasObjectProcessor, CasProcessor

    public class CasObjectNetworkCasProcessorImpl
    extends java.lang.Object
    implements CasObjectProcessor
    Implementation of the CasObjectProcessor interface used for both Local and Remote CasObjectProcessors. This objects plugs in a transport object defined in the CPE Descriptor and uses it to delegate analysis of CAS to a remote AE.
    • Field Detail

      • name

        private java.lang.String name
        The name.
      • socket

        private java.net.Socket socket
        The socket.
      • timeout

        private long timeout
        The timeout.
    • Constructor Detail

      • CasObjectNetworkCasProcessorImpl

        public CasObjectNetworkCasProcessorImpl​(CpeCasProcessor aCasProcessor)
                                         throws ResourceConfigurationException
        Using information from the CPE descriptor creates an instance of Transport class. The transport class will delegate analysis of CAS to a remote object.
        Parameters:
        aCasProcessor - - Cas Process configuration from the CPE descriptor
        Throws:
        ResourceConfigurationException - the resource configuration exception
    • Method Detail

      • pluginTransport

        private SocketTransport pluginTransport​(java.lang.String aTransportClass)
                                         throws java.lang.Exception
        Create Transport object from a given class and associate it with this CasProcessor.
        Parameters:
        aTransportClass - - name of the Transport class
        Returns:
        - instance of SocketTransport
        Throws:
        java.lang.Exception - passthru
      • getEndpoint

        public java.net.URL getEndpoint()
        Creates URL object containing service endpoint info ( host and port).
        Returns:
        URL
      • typeSystemInit

        public void typeSystemInit​(TypeSystem aTypeSystem)
                            throws ResourceInitializationException
        Description copied from interface: CasObjectProcessor
        Informs this CasConsumer that the CAS TypeSystem has changed. The CPM calls this method prior to initiating collection processing, and will call it again whenever the CAS TypeSystem changes.

        In this method, the CasConsumer should use the TypeSystem to resolve the names of Type and Features to the actual Type and Feature objects, which can then be used during processing.

        Specified by:
        typeSystemInit in interface CasObjectProcessor
        Parameters:
        aTypeSystem - the type system to use
        Throws:
        ResourceInitializationException - if the type system is not compatible with this Cas Consumer
      • isStateless

        public boolean isStateless()
        Description copied from interface: CasProcessor
        Gets whether this is a stateless CAS Processor. Stateless CAS Processors do not maintain any data between calls to their process methods.
        Specified by:
        isStateless in interface CasProcessor
        Returns:
        true if this CAS processor is stateless, false if it is stateful.
      • isReadOnly

        public boolean isReadOnly()
        Description copied from interface: CasProcessor
        Gets whether this is a read-only CAS Processor, which does not modify the CAS.
        Specified by:
        isReadOnly in interface CasProcessor
        Returns:
        true if this CAS processor does not modify the CAS, false if it does.
      • batchProcessComplete

        public void batchProcessComplete​(ProcessTrace aTrace)
                                  throws ResourceProcessException,
                                         java.io.IOException
        Description copied from interface: CasProcessor
        Completes the processing of a batch. A collection may be divided into one or more batches - it is up to the CollectionProcessingManager or the application to determine the number and size of batches.
        Specified by:
        batchProcessComplete in interface CasProcessor
        Parameters:
        aTrace - an object that records information, such as timing, about this method's execution.
        Throws:
        ResourceProcessException - if an exception occurs during processing
        java.io.IOException - if an I/O failure occurs