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

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

public class AmqpDistribution
extends java.lang.Object
implements DistributionHandler


Constructor Summary
AmqpDistribution()
           
 
Method Summary
 void close()
          Closes this handler and releases any system resources associated to it.
 void distribute(Message message)
          Distributes the given message outside of the JORAM server.
 void init(java.util.Properties properties)
          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
 

Constructor Detail

AmqpDistribution

public AmqpDistribution()
Method Detail

init

public void init(java.util.Properties properties)
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 message)
                throws java.lang.Exception
Description copied from interface: DistributionHandler
Distributes the given message outside of the JORAM server.

Specified by:
distribute in interface DistributionHandler
Parameters:
message - the message to distribute
Throws:
java.lang.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


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