public class JMSAcquisition extends Object implements AcquisitionDaemon
Modifier and Type | Class and Description |
---|---|
private static class |
JMSAcquisition.ConnectionUpdater
Daemon used to periodically update the pool of connections known by the
acquisition destinations.
|
(package private) class |
JMSAcquisition.JmsListener |
Modifier and Type | Field and Description |
---|---|
private boolean |
closing |
private List<String> |
connectionNames
If routing prop has been set, it defines a list of connection to use.
|
private static JMSAcquisition.ConnectionUpdater |
connectionUpdater |
private Destination |
dest
Foreign JMS destination object.
|
private static String |
DESTINATION_NAME_PROP |
private String |
destName
The JNDI name of the foreign JMS destination.
|
private static String |
DURABLE_SUBSCRIPTION_PROP |
private String |
durableSubscriptionName |
private Map<String,JMSAcquisition.JmsListener> |
listeners |
private static Logger |
logger |
private static String |
ROUTING_PROP |
protected String |
selector
Selector for filtering messages.
|
private static String |
SELECTOR_PROP |
private ReliableTransmitter |
transmitter |
private static String |
UPDATE_PERIOD_PROP |
Constructor and Description |
---|
JMSAcquisition() |
Modifier and Type | Method and Description |
---|---|
void |
start(Properties properties,
ReliableTransmitter transmitter)
Tells the daemon to start with the given properties.
|
void |
stop()
Tells the daemon to stop.
|
void |
updateConnections()
Create a new JMS consumer for each connection available.
|
private static final Logger logger
private static final String DESTINATION_NAME_PROP
private static final String UPDATE_PERIOD_PROP
private static final String ROUTING_PROP
private static final String DURABLE_SUBSCRIPTION_PROP
private static final String SELECTOR_PROP
private static JMSAcquisition.ConnectionUpdater connectionUpdater
private ReliableTransmitter transmitter
private Map<String,JMSAcquisition.JmsListener> listeners
private List<String> connectionNames
private volatile boolean closing
private String destName
private Destination dest
protected String selector
private String durableSubscriptionName
public void start(Properties properties, ReliableTransmitter transmitter)
AcquisitionDaemon
start
in interface AcquisitionDaemon
properties
- The initial set of properties.transmitter
- a transmitter used to transmit retrieved messages to the MOM
reliably.public void stop()
AcquisitionDaemon
stop
in interface AcquisitionDaemon
public void updateConnections()
Copyright © 2022 ScalAgent D.T.. All rights reserved.