| | |
| | | * |
| | | * |
| | | * Copyright 2007-2009 Sun Microsystems, Inc. |
| | | * Portions copyright 2011 ForgeRock AS |
| | | * Portions copyright 2011-2012 ForgeRock AS |
| | | */ |
| | | package org.opends.server.replication.server; |
| | | import static org.opends.messages.BackendMessages.*; |
| | |
| | | AddMsg addMsg = (AddMsg)msg; |
| | | AddOperation addOperation = (AddOperation)msg.createOperation(conn); |
| | | |
| | | dn = DN.decode("puid=" + addMsg.getParentUid() + "+" + |
| | | dn = DN.decode("puid=" + addMsg.getParentEntryUUID() + "+" + |
| | | CHANGE_NUMBER + "=" + msg.getChangeNumber().toString() + "+" + |
| | | msg.getDn() + "," + BASE_DN); |
| | | |
| | |
| | | { |
| | | DeleteMsg delMsg = (DeleteMsg)msg; |
| | | |
| | | dn = DN.decode("uuid=" + msg.getUniqueId() + "," + |
| | | dn = DN.decode("uuid=" + msg.getEntryUUID() + "," + |
| | | CHANGE_NUMBER + "=" + delMsg.getChangeNumber().toString()+ "," + |
| | | msg.getDn() +","+ BASE_DN); |
| | | |
| | |
| | | { |
| | | ModifyOperation op = (ModifyOperation)msg.createOperation(conn); |
| | | |
| | | dn = DN.decode("uuid=" + msg.getUniqueId() + "," + |
| | | dn = DN.decode("uuid=" + msg.getEntryUUID() + "," + |
| | | CHANGE_NUMBER + "=" + msg.getChangeNumber().toString()+ "," + |
| | | msg.getDn() +","+ BASE_DN); |
| | | op.setInternalOperation(true); |
| | |
| | | { |
| | | ModifyDNOperation op = (ModifyDNOperation)msg.createOperation(conn); |
| | | |
| | | dn = DN.decode("uuid=" + msg.getUniqueId() + "," + |
| | | dn = DN.decode("uuid=" + msg.getEntryUUID() + "," + |
| | | CHANGE_NUMBER + "=" + msg.getChangeNumber().toString()+ "," + |
| | | msg.getDn() +","+ BASE_DN); |
| | | op.setInternalOperation(true); |