Lines Matching refs:broker
135 ReplicationBroker broker = openReplicationSession(
151 broker.publish(addMsg(addDN, entry, sequence + 1, sequence, gen));
152 broker.publish(modifyMsg(addDN, sequence + 1, generatemods("description", "test"), gen));
191 broker.publish(delMsg(deleteDN, sequence + 1, gen));
255 // Create replication server, replication domain and broker.
270 ReplicationBroker broker = openReplicationSession(
279 broker.publish(addMsg(addDN, entry, renamedEntryUuid, 1, gen));
288 broker.publish(modDNMsg(addDN, "dc=new_name", renamedEntryUuid, 1, gen));
290 broker.publish(delMsg(delDN, renamedEntryUuid, gen));
363 ReplicationBroker broker = openReplicationSession(
377 broker.publish(addMsg(addDN, entry, sequence + 1, 1, gen));
378 broker.publish(delMsg(addDN, sequence + 1, gen));
384 broker.publish(addMsg(addDN, entry, sequence + 1025, 1, gen));
401 broker.publish(delMsg(deleteDN, sequence + 1025, gen));
467 ReplicationBroker broker = openReplicationSession(
483 broker.publish(addMsg(addDN, entry, sequence + 1, 1, gen));
486 broker.publish(modDNMsg(addDN, "dc=new_dep" + sequence, sequence + 1, 1, gen));
505 broker.publish(delMsg(addDN, sequence + 1, gen));