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

All Implemented Interfaces:

DistributionHandler
```
public class AmqpDistribution
extends Object
implements DistributionHandler
```
Distribution handler for the AMQP distribution bridge.

Field Summary

Fields
Modifier and Type	Field	Description
`private String`	`amqpQueue`
`private boolean`	`amqpQueueAutoDelete`
`private boolean`	`amqpQueueDurable`
`private boolean`	`amqpQueueExclusive`
`private boolean`	`amqpQueuePassive`
`private LinkedHashMap<String,com.rabbitmq.client.Channel>`	`channels`
`private List<String>`	`connectionNames`
`private static boolean`	`DEBUG`
`private long`	`lastUpdate`
`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 static String`	`UPDATE_PERIOD_PROP`
`private long`	`updatePeriod`

Constructor Summary

Constructors
Constructor Description

AmqpDistribution()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`	Closes this handler and releases any system resources associated to it.
`void`	`distribute(Message fullMessage)`	Distributes the given message outside of the JORAM server.
`void`	`init(Properties properties, boolean firstTime)`	Configures the handler with the given properties.

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
  - channels
```
private LinkedHashMap<String,com.rabbitmq.client.Channel> channels
```
  - connectionNames
```
private List<String> connectionNames
```
  - amqpQueue
```
private String amqpQueue
```
  - amqpQueuePassive
```
private boolean amqpQueuePassive
```
  - amqpQueueExclusive
```
private boolean amqpQueueExclusive
```
  - amqpQueueDurable
```
private boolean amqpQueueDurable
```
  - amqpQueueAutoDelete
```
private boolean amqpQueueAutoDelete
```
  - lastUpdate
```
private long lastUpdate
```
  - updatePeriod
```
private long updatePeriod
```
- Constructor Detail
  - AmqpDistribution
```
public AmqpDistribution()
```
- Method Detail
  - init
```
public void init(Properties properties,
                 boolean firstTime)
```
    Description copied from interface: DistributionHandler
    
    Configures the handler with the given properties.
    
    Specified by:
    
    init in interface DistributionHandler
    
    Parameters:
    
    properties - The initial set of properties.
  - distribute
```
public void distribute(Message fullMessage)
                throws Exception
```
    Description copied from interface: DistributionHandler
    
    Distributes the given message outside of the JORAM server.
    
    Specified by:
    
    distribute in interface DistributionHandler
    
    Parameters:
    
    fullMessage - the message to distribute
    
    Throws:
    
    Exception - if the message could not be distributed. The message will be forwarded to a DMQ, if any.
  - close
```
public void close()
```
    Description copied from interface: DistributionHandler
    
    Closes this handler and releases any system resources associated to it. There will be no subsequent call to this handler after it has been closed.
    
    Specified by:
    
    close in interface DistributionHandler

Class AmqpDistribution

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

channels

connectionNames

amqpQueue

amqpQueuePassive

amqpQueueExclusive

amqpQueueDurable

amqpQueueAutoDelete

lastUpdate

updatePeriod

Constructor Detail

AmqpDistribution

Method Detail

init

distribute

close