Searched defs:broker2 (Results 1 - 15 of 15) sorted by relevance

/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java95 private ReplicationBroker broker2 = null; field in class:GenerationIdTest
756 broker2 = openReplicationSession(baseDn,
780 broker2.publish(createAddMsg());
822 broker2.stop();
823 broker2 = null;
858 debugInfo("Create again broker2");
859 broker2 = openReplicationSession(baseDn,
861 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server");
895 ChangeStatusMsg csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker2,
954 ReplicationMsg msg = broker2
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java89 private ReplicationBroker broker2 = null; field in class:MonitorTest
381 debugInfo("Connecting broker2 to replServer1");
382 broker2 = openReplicationSession(baseDn,
462 if (broker2 != null)
463 broker2.stop();
464 broker2 = null;
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java81 private ReplicationBroker broker2; field in class:MonitorTest
327 debugInfo("Connecting broker2 to replServer1");
328 broker2 = openReplicationSession(baseDN,
398 stop(broker2, broker3, broker4);
399 broker2 = broker3 = broker4 = null;
H A DReplicationServerTest.java654 ReplicationBroker broker2 = null;
682 broker2 = openReplicationSession(TEST_ROOT_DN, brokerIds[1], 100, changelogPorts[0], 1000);
721 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4);
728 stop(broker1, broker2);
752 ReplicationBroker broker2 = null;
821 broker2 = openReplicationSession(TEST_ROOT_DN,
825 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4);
832 stop(broker1, broker2);
837 private List<ReplicationMsg> receiveReplicationMsgs(ReplicationBroker broker2, int nbMessagesExpected) argument
844 ReplicationMsg msg = broker2
1203 assertOnlyTopologyMsgsReceived(ReplicationBroker broker2) argument
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java95 private ReplicationBroker broker2 = null; field in class:GenerationIdTest
756 broker2 = openReplicationSession(baseDn,
780 broker2.publish(createAddMsg());
822 broker2.stop();
823 broker2 = null;
858 debugInfo("Create again broker2");
859 broker2 = openReplicationSession(baseDn,
861 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server");
895 ChangeStatusMsg csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker2,
954 ReplicationMsg msg = broker2
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java89 private ReplicationBroker broker2 = null; field in class:MonitorTest
381 debugInfo("Connecting broker2 to replServer1");
382 broker2 = openReplicationSession(baseDn,
462 if (broker2 != null)
463 broker2.stop();
464 broker2 = null;
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java81 private ReplicationBroker broker2; field in class:MonitorTest
327 debugInfo("Connecting broker2 to replServer1");
328 broker2 = openReplicationSession(baseDN,
398 stop(broker2, broker3, broker4);
399 broker2 = broker3 = broker4 = null;
H A DReplicationServerTest.java654 ReplicationBroker broker2 = null;
682 broker2 = openReplicationSession(TEST_ROOT_DN, brokerIds[1], 100, changelogPorts[0], 1000);
721 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4);
728 stop(broker1, broker2);
752 ReplicationBroker broker2 = null;
821 broker2 = openReplicationSession(TEST_ROOT_DN,
825 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4);
832 stop(broker1, broker2);
837 private List<ReplicationMsg> receiveReplicationMsgs(ReplicationBroker broker2, int nbMessagesExpected) argument
844 ReplicationMsg msg = broker2
1203 assertOnlyTopologyMsgsReceived(ReplicationBroker broker2) argument
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java95 private ReplicationBroker broker2 = null; field in class:GenerationIdTest
756 broker2 = openReplicationSession(baseDn,
780 broker2.publish(createAddMsg());
822 broker2.stop();
823 broker2 = null;
858 debugInfo("Create again broker2");
859 broker2 = openReplicationSession(baseDn,
861 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server");
895 ChangeStatusMsg csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker2,
954 ReplicationMsg msg = broker2
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java89 private ReplicationBroker broker2 = null; field in class:MonitorTest
381 debugInfo("Connecting broker2 to replServer1");
382 broker2 = openReplicationSession(baseDn,
462 if (broker2 != null)
463 broker2.stop();
464 broker2 = null;
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DMonitorTest.java81 private ReplicationBroker broker2; field in class:MonitorTest
329 debugInfo("Connecting broker2 to replServer1");
330 broker2 = openReplicationSession(baseDN,
400 stop(broker2, broker3, broker4);
401 broker2 = broker3 = broker4 = null;
H A DReplicationServerTest.java652 ReplicationBroker broker2 = null;
680 broker2 = openReplicationSession(TEST_ROOT_DN, brokerIds[1], 100, changelogPorts[0], 1000);
719 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4);
726 stop(broker1, broker2);
750 ReplicationBroker broker2 = null;
819 broker2 = openReplicationSession(TEST_ROOT_DN,
823 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4);
830 stop(broker1, broker2);
835 private List<ReplicationMsg> receiveReplicationMsgs(ReplicationBroker broker2, int nbMessagesExpected) argument
842 ReplicationMsg msg = broker2
1206 assertOnlyTopologyMsgsReceived(ReplicationBroker broker2) argument
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java93 private ReplicationBroker broker2; field in class:GenerationIdTest
650 broker2 =
664 broker2.publish(createAddMsg());
692 stop(broker2, broker3);
693 broker2 = broker3 = null;
719 debugInfo("Create again broker2");
720 broker2 = openReplicationSession(baseDN,
722 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server");
742 ChangeStatusMsg csMsg = waitForSpecificMsg(broker2, ChangeStatusMsg.class);
784 assertNoMessageReceived(broker2, "broker
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java93 private ReplicationBroker broker2; field in class:GenerationIdTest
650 broker2 =
664 broker2.publish(createAddMsg());
692 stop(broker2, broker3);
693 broker2 = broker3 = null;
719 debugInfo("Create again broker2");
720 broker2 = openReplicationSession(baseDN,
722 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server");
742 ChangeStatusMsg csMsg = waitForSpecificMsg(broker2, ChangeStatusMsg.class);
784 assertNoMessageReceived(broker2, "broker
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DGenerationIdTest.java106 private ReplicationBroker broker2; field in class:GenerationIdTest
635 broker2 = openReplicationSession(server2ID, replServer1, dsGenId + 1);
645 broker2.publish(createAddMsg());
673 stop(broker2, broker3);
674 broker2 = broker3 = null;
700 debugInfo("Create again broker2");
701 broker2 = openReplicationSession(server2ID, replServer1, dsGenId);
702 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server");
721 ChangeStatusMsg csMsg = waitForSpecificMsg(broker2, ChangeStatusMsg.class);
765 assertNoMessageReceived(broker2, "broker
[all...]

Completed in 57 milliseconds