Class DistributionModule


  • public class DistributionModule
    extends Object
    • Field Detail

      • logger

        private static final Logger logger
      • DEBUG

        private static final boolean DEBUG
      • distributionHandler

        private DistributionHandler distributionHandler
        Holds the distribution logic.
      • isAsyncDistribution

        private boolean isAsyncDistribution
    • Constructor Detail

      • DistributionModule

        public DistributionModule​(String className,
                                  Properties properties,
                                  boolean firstTime)
    • Method Detail

      • setProperties

        public void setProperties​(Properties properties,
                                  boolean firstTime)
        Resets the distribution properties.
      • close

        public void close()
        Close the DistributionHandler. Closes the specific distribution module and all associated resources.
      • processMessage

        public void processMessage​(Message fullMessage)
                            throws Exception
        Be careful, the message must be completely loaded (body).
        Parameters:
        fullMessage -
        Throws:
        Exception