java.lang.Object
- org.objectweb.joram.mom.dest.jms.JMSAcquisition

All Implemented Interfaces:

AcquisitionDaemon
```
public class JMSAcquisition
extends Object
implements AcquisitionDaemon
```
Acquisition daemon for the JMS acquisition bridge.

Nested Class Summary

Nested Classes
Modifier and Type	Class	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`

Field Summary

Fields
Modifier and Type	Field	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 static boolean`	`DEBUG`
`private jakarta.jms.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 Summary

Constructors
Constructor Description

JMSAcquisition()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - logger
```
private static final Logger logger
```
  - DEBUG
```
private static final boolean DEBUG
```
  - DESTINATION_NAME_PROP
```
private static final String DESTINATION_NAME_PROP
```
    See Also:
    
    Constant Field Values
  - UPDATE_PERIOD_PROP
```
private static final String UPDATE_PERIOD_PROP
```
    See Also:
    
    Constant Field Values
  - ROUTING_PROP
```
private static final String ROUTING_PROP
```
    See Also:
    
    Constant Field Values
  - DURABLE_SUBSCRIPTION_PROP
```
private static final String DURABLE_SUBSCRIPTION_PROP
```
    See Also:
    
    Constant Field Values
  - SELECTOR_PROP
```
private static final String SELECTOR_PROP
```
    See Also:
    
    Constant Field Values
  - connectionUpdater
```
private static JMSAcquisition.ConnectionUpdater connectionUpdater
```
  - transmitter
```
private ReliableTransmitter transmitter
```
  - listeners
```
private Map<String,JMSAcquisition.JmsListener> listeners
```
  - connectionNames
```
private List<String> connectionNames
```
    If routing prop has been set, it defines a list of connection to use.
  - closing
```
private volatile boolean closing
```
  - destName
```
private String destName
```
    The JNDI name of the foreign JMS destination.
  - dest
```
private jakarta.jms.Destination dest
```
    Foreign JMS destination object.
  - selector
```
protected String selector
```
    Selector for filtering messages.
  - durableSubscriptionName
```
private String durableSubscriptionName
```
- Constructor Detail
  - JMSAcquisition
```
public JMSAcquisition()
```
- Method Detail
  - start
```
public void start(Properties properties,
                  ReliableTransmitter transmitter)
```
    Description copied from interface: AcquisitionDaemon
    
    Tells the daemon to start with the given properties.
    
    Specified by:
    
    start in interface AcquisitionDaemon
    
    Parameters:
    
    properties - The initial set of properties.
    
    transmitter - a transmitter used to transmit retrieved messages to the MOM reliably.
  - stop
```
public void stop()
```
    Description copied from interface: AcquisitionDaemon
    
    Tells the daemon to stop. Any system resources previously allocated must be released.
    
    Specified by:
    
    stop in interface AcquisitionDaemon
  - updateConnections
```
public void updateConnections()
```
    Create a new JMS consumer for each connection available.

Class JMSAcquisition

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

DEBUG

DESTINATION_NAME_PROP

UPDATE_PERIOD_PROP

ROUTING_PROP

DURABLE_SUBSCRIPTION_PROP

SELECTOR_PROP

connectionUpdater

transmitter

listeners

connectionNames

closing

destName

dest

selector

durableSubscriptionName

Constructor Detail

JMSAcquisition

Method Detail

start

stop

updateConnections