Searched defs:broker3 (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java96 private ReplicationBroker broker3 = null; field in class:GenerationIdTest
769 broker3 = openReplicationSession(baseDn,
783 broker3.receive();
807 ReplicationMsg msg = broker3.receive();
824 broker3.stop();
825 broker3 = null;
863 debugInfo("Create again broker3");
864 broker3 = openReplicationSession(baseDn,
866 assertTrue(broker3.isConnected(), "Broker3 failed to connect to replication server");
903 csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker3,
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java90 private ReplicationBroker broker3 = null; field in class:MonitorTest
393 debugInfo("Connecting broker3 to replServer2");
394 broker3 = openReplicationSession(baseDn,
436 broker3.publish(createAddMsg(gen.newChangeNumber(), server3ID));
465 if (broker3 != null)
466 broker3.stop();
467 broker3 = null;
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java82 private ReplicationBroker broker3; field in class:MonitorTest
338 debugInfo("Connecting broker3 to replServer2");
339 broker3 = openReplicationSession(baseDN,
374 broker3.publish(createAddMsg(gen.newCSN()));
398 stop(broker2, broker3, broker4);
399 broker2 = broker3 = broker4 = null;
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java96 private ReplicationBroker broker3 = null; field in class:GenerationIdTest
769 broker3 = openReplicationSession(baseDn,
783 broker3.receive();
807 ReplicationMsg msg = broker3.receive();
824 broker3.stop();
825 broker3 = null;
863 debugInfo("Create again broker3");
864 broker3 = openReplicationSession(baseDn,
866 assertTrue(broker3.isConnected(), "Broker3 failed to connect to replication server");
903 csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker3,
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java90 private ReplicationBroker broker3 = null; field in class:MonitorTest
393 debugInfo("Connecting broker3 to replServer2");
394 broker3 = openReplicationSession(baseDn,
436 broker3.publish(createAddMsg(gen.newChangeNumber(), server3ID));
465 if (broker3 != null)
466 broker3.stop();
467 broker3 = null;
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java82 private ReplicationBroker broker3; field in class:MonitorTest
338 debugInfo("Connecting broker3 to replServer2");
339 broker3 = openReplicationSession(baseDN,
374 broker3.publish(createAddMsg(gen.newCSN()));
398 stop(broker2, broker3, broker4);
399 broker2 = broker3 = broker4 = null;
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java96 private ReplicationBroker broker3 = null; field in class:GenerationIdTest
769 broker3 = openReplicationSession(baseDn,
783 broker3.receive();
807 ReplicationMsg msg = broker3.receive();
824 broker3.stop();
825 broker3 = null;
863 debugInfo("Create again broker3");
864 broker3 = openReplicationSession(baseDn,
866 assertTrue(broker3.isConnected(), "Broker3 failed to connect to replication server");
903 csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker3,
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DMonitorTest.java90 private ReplicationBroker broker3 = null; field in class:MonitorTest
393 debugInfo("Connecting broker3 to replServer2");
394 broker3 = openReplicationSession(baseDn,
436 broker3.publish(createAddMsg(gen.newChangeNumber(), server3ID));
465 if (broker3 != null)
466 broker3.stop();
467 broker3 = null;
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DMonitorTest.java82 private ReplicationBroker broker3; field in class:MonitorTest
340 debugInfo("Connecting broker3 to replServer2");
341 broker3 = openReplicationSession(baseDN,
376 broker3.publish(createAddMsg(gen.newCSN()));
400 stop(broker2, broker3, broker4);
401 broker2 = broker3 = broker4 = null;
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java94 private ReplicationBroker broker3; field in class:GenerationIdTest
656 broker3 =
666 broker3,
667 "broker3",
682 ReplicationMsg msg = broker3.receive();
692 stop(broker2, broker3);
693 broker2 = broker3 = null;
724 debugInfo("Create again broker3");
725 broker3 = openReplicationSession(baseDN,
727 assertTrue(broker3
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java94 private ReplicationBroker broker3; field in class:GenerationIdTest
656 broker3 =
666 broker3,
667 "broker3",
682 ReplicationMsg msg = broker3.receive();
692 stop(broker2, broker3);
693 broker2 = broker3 = null;
724 debugInfo("Create again broker3");
725 broker3 = openReplicationSession(baseDN,
727 assertTrue(broker3
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DGenerationIdTest.java107 private ReplicationBroker broker3; field in class:GenerationIdTest
639 broker3 = openReplicationSession(server3ID, replServer1, dsGenId);
647 broker3,
648 "broker3",
663 ReplicationMsg msg = broker3.receive();
673 stop(broker2, broker3);
674 broker2 = broker3 = null;
704 debugInfo("Create again broker3");
705 broker3 = openReplicationSession(server3ID, replServer1, dsGenId);
706 assertTrue(broker3
[all...]

Completed in 50 milliseconds