Package org.objectweb.joram.mom.dest
Class DistributionModule
- java.lang.Object
-
- org.objectweb.joram.mom.dest.DistributionModule
-
public class DistributionModule extends Object
-
-
Field Summary
Fields Modifier and Type Field Description private static booleanDEBUGprivate DistributionHandlerdistributionHandlerHolds the distribution logic.private booleanisAsyncDistributionprivate static Loggerlogger
-
Constructor Summary
Constructors Constructor Description DistributionModule(String className, Properties properties, boolean firstTime)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()Close the DistributionHandler.DistributionHandlergetDistributionHandler()voidprocessMessage(Message fullMessage)Be careful, the message must be completely loaded (body).voidsetProperties(Properties properties, boolean firstTime)Resets the distribution properties.
-
-
-
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
-
getDistributionHandler
public DistributionHandler getDistributionHandler()
-
-