Class URLAcquisition

    • Constructor Detail

      • URLAcquisition

        public URLAcquisition()
    • Method Detail

      • getResource

        private static byte[] getResource​(String spec,
                                          Properties prop)
                                   throws IOException
        get the file.
        Parameters:
        spec - the String to parse as a URL.
        Returns:
        the file in byte format.
        Throws:
        IOException
      • retrieve

        public void retrieve​(ReliableTransmitter transmitter)
                      throws Exception
        Check the URL resource. Store file in Queue or send to topic (collector destination.
        Specified by:
        retrieve in interface AcquisitionHandler
        Parameters:
        transmitter - a transmitter used to transmit retrieved messages to the MOM reliably.
        Throws:
        Exception
        See Also:
        com.scalagent.joram.mom.dest.collector.Collector#check()
      • setProperties

        public void setProperties​(Properties properties)
        Description copied from interface: AcquisitionHandler
        Configures the handler with the given properties. This method is called one time before the first call to retrieve and then when the acquisition destination receives a configuration message.
        Specified by:
        setProperties in interface AcquisitionHandler
        Parameters:
        properties - The new set of properties.
      • close

        public void close()
        Description copied from interface: AcquisitionHandler
        Closes this handler and releases any system resources associated to it. There will be no subsequent call to this handler after it has been closed.
        Specified by:
        close in interface AcquisitionHandler