java.lang.Object
- org.objectweb.joram.mom.dest.amqp.AmqpAcquisition

All Implemented Interfaces:

AcquisitionDaemon
```
public class AmqpAcquisition
extends Object
implements AcquisitionDaemon
```
Acquisition daemon for the AMQP acquisition bridge.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`private class`	`AmqpAcquisition.AmqpConsumer`
`private static class`	`AmqpAcquisition.ConnectionUpdater`	Daemon used to periodically update the pool of connections known by the acquisition destinations.

Field Summary

Fields
Modifier and Type	Field	Description
`private String`	`amqpQueue`	The name of the foreign AMQP queue.
`private boolean`	`amqpQueueAutoDelete`
`private boolean`	`amqpQueueDurable`
`private boolean`	`amqpQueueExclusive`
`private boolean`	`amqpQueuePassive`
`private Map<String,com.rabbitmq.client.Channel>`	`channels`
`private boolean`	`closing`
`private List<String>`	`connectionNames`	If routing prop has been set, it defines a list of connection to use.
`private static AmqpAcquisition.ConnectionUpdater`	`connectionUpdater`
`private static boolean`	`DEBUG`
`private static Logger`	`logger`
`private static String`	`QUEUE_AUTODELETE_PROP`	True if we are declaring an autodelete queue (server will delete it when no longer in use).
`private static String`	`QUEUE_DURABLE_PROP`	True if we are declaring a durable queue (the queue will survive a server restart).
`private static String`	`QUEUE_EXCLUSIVE_PROP`	True if we are declaring an exclusive queue (restricted to this connection).
`private static String`	`QUEUE_NAME_PROP`	the name of the queue to declare
`private static String`	`QUEUE_PASSIVE_PROP`	True if we are declaring a queue passively; i.e., check if it exists.
`private static String`	`ROUTING_PROP`
`private ReliableTransmitter`	`transmitter`
`private static String`	`UPDATE_PERIOD_PROP`

Constructor Summary

Constructors
Constructor Description

AmqpAcquisition()

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(List<LiveServerConnection> connections)`	Create a new AMQP 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
```
  - QUEUE_NAME_PROP
```
private static final String QUEUE_NAME_PROP
```
    the name of the queue to declare
    
    See Also:
    
    Constant Field Values
  - QUEUE_PASSIVE_PROP
```
private static final String QUEUE_PASSIVE_PROP
```
    True if we are declaring a queue passively; i.e., check if it exists. Default value is true.
    
    See Also:
    
    Constant Field Values
  - QUEUE_EXCLUSIVE_PROP
```
private static final String QUEUE_EXCLUSIVE_PROP
```
    True if we are declaring an exclusive queue (restricted to this connection). Default value is false.
    
    See Also:
    
    Constant Field Values
  - QUEUE_DURABLE_PROP
```
private static final String QUEUE_DURABLE_PROP
```
    True if we are declaring a durable queue (the queue will survive a server restart). Default value is true.
    
    See Also:
    
    Constant Field Values
  - QUEUE_AUTODELETE_PROP
```
private static final String QUEUE_AUTODELETE_PROP
```
    True if we are declaring an autodelete queue (server will delete it when no longer in use). Default value is false.
    
    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
  - connectionUpdater
```
private static AmqpAcquisition.ConnectionUpdater connectionUpdater
```
  - transmitter
```
private ReliableTransmitter transmitter
```
  - channels
```
private Map<String,com.rabbitmq.client.Channel> channels
```
  - connectionNames
```
private List<String> connectionNames
```
    If routing prop has been set, it defines a list of connection to use.
  - amqpQueue
```
private String amqpQueue
```
    The name of the foreign AMQP queue.
  - amqpQueuePassive
```
private boolean amqpQueuePassive
```
  - amqpQueueExclusive
```
private boolean amqpQueueExclusive
```
  - amqpQueueDurable
```
private boolean amqpQueueDurable
```
  - amqpQueueAutoDelete
```
private boolean amqpQueueAutoDelete
```
  - closing
```
private volatile boolean closing
```
- Constructor Detail
  - AmqpAcquisition
```
public AmqpAcquisition()
```
- 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(List<LiveServerConnection> connections)
```
    Create a new AMQP consumer for each connection available.

Class AmqpAcquisition

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

DEBUG

QUEUE_NAME_PROP

QUEUE_PASSIVE_PROP

QUEUE_EXCLUSIVE_PROP

QUEUE_DURABLE_PROP

QUEUE_AUTODELETE_PROP

UPDATE_PERIOD_PROP

ROUTING_PROP

connectionUpdater

transmitter

channels

connectionNames

amqpQueue

amqpQueuePassive

amqpQueueExclusive

amqpQueueDurable

amqpQueueAutoDelete

closing

Constructor Detail

AmqpAcquisition

Method Detail

start

stop

updateConnections