org.objectweb.joram.mom.dest.amqp
Class AmqpAcquisition

java.lang.Object
  extended by org.objectweb.joram.mom.dest.amqp.AmqpAcquisition
All Implemented Interfaces:
AcquisitionDaemon

public class AmqpAcquisition
extends java.lang.Object
implements AcquisitionDaemon


Constructor Summary
AmqpAcquisition()
           
 
Method Summary
 void onNewConnections(java.util.List<com.rabbitmq.client.Connection> connections)
          Create a new AMQP consumer for each connection available.
 void start(java.util.Properties properties, ReliableTransmitter transmitter)
          Tells the daemon to start with the given properties.
 void stop()
          Tells the daemon to stop.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AmqpAcquisition

public AmqpAcquisition()
Method Detail

start

public void start(java.util.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

onNewConnections

public void onNewConnections(java.util.List<com.rabbitmq.client.Connection> connections)
Create a new AMQP consumer for each connection available.



Copyright © 2011 ScalAgent D.T.. All Rights Reserved.