public class JMSDistribution extends Object implements DistributionHandler
Modifier and Type | Class and Description |
---|---|
private class |
JMSDistribution.SessionAndProducer |
Modifier and Type | Field and Description |
---|---|
private List<String> |
connectionNames |
private static String |
DESTINATION_NAME_PROP |
private String |
destName
Destination JNDI name.
|
private long |
lastUpdate |
(package private) long |
lastwarn |
private static org.objectweb.util.monolog.api.Logger |
logger |
private static String |
ROUTING_PROP |
private LinkedHashMap<String,JMSDistribution.SessionAndProducer> |
sessions |
private static String |
UPDATE_PERIOD_PROP |
private long |
updatePeriod |
Constructor and Description |
---|
JMSDistribution() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this handler and releases any system resources associated to it.
|
void |
distribute(Message message)
Distributes the given message outside of the JORAM server.
|
void |
init(Properties properties,
boolean firstTime)
Configures the handler with the given properties.
|
private static final org.objectweb.util.monolog.api.Logger logger
private static final String DESTINATION_NAME_PROP
private static final String UPDATE_PERIOD_PROP
private static final String ROUTING_PROP
private LinkedHashMap<String,JMSDistribution.SessionAndProducer> sessions
private String destName
private long lastUpdate
private long updatePeriod
long lastwarn
public void init(Properties properties, boolean firstTime)
DistributionHandler
init
in interface DistributionHandler
properties
- The initial set of properties.public void distribute(Message message) throws Exception
DistributionHandler
distribute
in interface DistributionHandler
message
- the message to distributeException
- if the message could not be distributed. The message will
be forwarded to a DMQ, if any.public void close()
DistributionHandler
close
in interface DistributionHandler
Copyright © 2019 ScalAgent D.T.. All rights reserved.