### Question:
ReplicationServer implements ConfigurationChangeListener<ReplicationServerCfg> { public ReplicationServer(ReplicationServerCfg cfg) throws ConfigException { this(cfg, new DSRSShutdownSync(), new ECLEnabledDomainPredicate()); } ReplicationServer(ReplicationServerCfg cfg);  ReplicationServer(ReplicationServerCfg cfg, DSRSShutdownSync dsrsShutdownSync);  ReplicationServer(final ReplicationServerCfg cfg, final DSRSShutdownSync dsrsShutdownSync,
      final ECLEnabledDomainPredicate predicate); static List<ReplicationServer> getAllInstances(); ReplicationServerDomain getReplicationServerDomain(DN baseDN); void validateCookie(MultiDomainServerState cookie, Set<DN> ignoredBaseDNs); ReplicationServerDomain getReplicationServerDomain(DN baseDN,
      boolean create); void shutdown(); long getPurgeDelay(); static boolean isConfigurationAcceptable(
      ReplicationServerCfg configuration, List<LocalizableMessage> unacceptableReasons); @Override ConfigChangeResult applyConfigurationChange(
      ReplicationServerCfg configuration); @Override boolean isConfigurationChangeAcceptable(
      ReplicationServerCfg configuration, List<LocalizableMessage> unacceptableReasons); long getGenerationId(DN baseDN); int getServerId(); void remove(); Iterator<ReplicationServerDomain> getDomainIterator(); long getAssuredTimeout(); byte getGroupId(); int getDegradedStatusThreshold(); long getMonitoringPublisherPeriod(); String getMonitorInstanceName(); int getReplicationPort(); String getServerURL(); static void onlyForTestsAddlocalReplicationServer(String server); static void onlyForTestsClearLocalReplicationServerList(); static boolean isLocalReplicationServerPort(int port); long getOldestChangeNumber(); long getNewestChangeNumber(); MultiDomainServerState getNewestECLCookie(Set<DN> excludedBaseDNs); int getWeight(); ChangelogDB getChangelogDB(); boolean isChangeNumberEnabled(); boolean isECLEnabled(); @Override String toString();  }### Answer:
@Test(enabled = true) public void replicationServerTest() throws Exception { ReplicationBroker[] brokers1And2 = null; try { brokers1And2 = changelogBasic(); newClientLateServer1(); newClient(); newClientWithFirstChanges(); newClientWithChangefromServer1(); newClientWithChangefromServer2(); newClientWithUnknownChanges(); } finally { stop(brokers1And2); } stopChangelog(); }