Cross Reference: /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/UpdateOperationTest.java

Lines Matching refs:broker
68  * the replication server broker interface.
290    * FIXME Enable this test when broker suspend/resume receive are implemented.
299      * Open a session to the replicationServer using the broker API.
303     ReplicationBroker broker =
314       broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
323       broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
330       broker.publish(
338       broker.stop();
360      * Open a session to the replicationServer using the broker API.
364     ReplicationBroker broker =
372       broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
381       broker.publish(modMsg);
396       broker.publish(modMsg);
403       broker.publish(
410       broker.stop();
434      * Open a session to the replicationServer using the broker API.
437     ReplicationBroker broker =
473       broker.publish(modMsg);
481       broker.publish(modMsg);
511       broker.publish(modMsg);
519       broker.publish(modMsg);
533       broker.stop();
557      * Open a session to the replicationServer using the ReplicationServer broker API.
561     ReplicationBroker broker =
575       broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
587     broker.publish(modMsg);
609     broker.publish(modMsg);
627       broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
639     broker.publish(modMsg);
661       broker.publish(new DeleteMsg(delDN, gen.newCSN(), user1entryUUID));
675       broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID));
684       broker.publish(addMsg(gen, personWithSecondUniqueID, user1entrysecondUUID, baseUUID));
695     broker.publish(
697     broker.publish(
720     broker.publish(addMsg);
740       broker.publish(
765     broker.publish(modDnMsg);
779     broker.publish(modDnMsg);
796       broker.publish(addMsg(gen, personWithSecondUniqueID, user1entrysecondUUID, baseUUID));
808       broker.publish(modDnMsg);
822       broker.publish(new DeleteMsg(delDN2, gen.newCSN(), user1entrysecondUUID));
826       broker.publish(new DeleteMsg(reallyNewDN, gen.newCSN(), user1entryUUID));
885       broker.publish(addMsg);
918       broker.publish(new DeleteMsg(domain1dn, olderCSN, domain1uid));
959       broker.publish(new DeleteMsg(domain1dn, gen.newCSN(), domain1uid));
979       broker.publish(addMsg(gen, domain2, domain2uid, domain1uid));
1002     broker.publish(modDnMsg);
1021     broker.publish(modDnMsg);
1031       broker.stop();
1109     ReplicationBroker broker =
1116        * replicationServer and forwarded to our replicationServer broker session.
1125       assertClientReceivesExpectedMsg(broker, AddMsg.class, personEntry.getName());
1130       assertClientReceivesExpectedMsg(broker, ModifyMsg.class, personEntry.getName());
1140       assertClientReceivesExpectedMsg(broker, ModifyDNMsg.class, personEntry.getName());
1146       assertClientReceivesExpectedMsg(broker, DeleteMsg.class, newDN);
1156       broker.publish(addMsg);
1171       broker.publish(modMsg);
1182       broker.publish(modMsg);
1195       broker.publish(moddnMsg);
1205       broker.publish(delMsg);
1212       broker.stop();
1216   private void assertClientReceivesExpectedMsg(ReplicationBroker broker,
1219     final ReplicationMsg msg = broker.receive();
1270     ReplicationBroker broker =
1314         broker.publish(new DeleteMsg(tmp.getName(), gen.newCSN(), uuid));
1338       broker.stop();
1373      * Open a session to the replicationServer using the broker API.
1377     ReplicationBroker broker =
1379     consumeAllMessages(broker); // clean leftover messages from lostHeartbeatFailover()
1387       broker.publish(addMsg);
1398       ReplicationMsg msg = broker.receive();
1406       broker.publish(
1415       broker.stop();
1420    * Consumes all the messages sent to this broker. This is useful at the start
1423   private void consumeAllMessages(ReplicationBroker broker)
1430         msgs.add(broker.receive());