com.cloudtran.replicator.link.rabbitmq
Class RmqLinkInitializer

java.lang.Object
  extended by com.cloudtran.replicator.link.AbstractLinkInitializer
      extended by com.cloudtran.replicator.link.rabbitmq.RmqLinkInitializer
All Implemented Interfaces:
LinkInitializer, RmqConnectionChecker

public class RmqLinkInitializer
extends AbstractLinkInitializer
implements RmqConnectionChecker


Constructor Summary
RmqLinkInitializer()
           
 
Method Summary
 void connectionClosed(Exception e, Integer linkId)
           
 Link[] initialize()
           
 List<LinkProvider> initialize(boolean thisMachineIsServer, String remoteDataCenterName, int port, List<InetAddress> inetAddresses)
          Same as the String form, but the initialization string is converted into a list of InetAddress's.
 
Methods inherited from class com.cloudtran.replicator.link.AbstractLinkInitializer
initialize
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RmqLinkInitializer

public RmqLinkInitializer()
Method Detail

initialize

public Link[] initialize()

connectionClosed

public void connectionClosed(Exception e,
                             Integer linkId)
Specified by:
connectionClosed in interface RmqConnectionChecker

initialize

public List<LinkProvider> initialize(boolean thisMachineIsServer,
                                     String remoteDataCenterName,
                                     int port,
                                     List<InetAddress> inetAddresses)
Description copied from interface: LinkInitializer
Same as the String form, but the initialization string is converted into a list of InetAddress's. The format of the string will be validated, but no connection is made by the replication framework, so the initialize() method must be prepared for the remote machine to be temporarily unavailable.

Specified by:
initialize in interface LinkInitializer
Returns:
null if the links cannot be configured.