From dfbe880eb338a1d752ce790f689b5133761d7079 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 26 Sep 2013 07:35:55 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java b/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java
index db47298..d06b6af 100644
--- a/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java
+++ b/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java
@@ -31,6 +31,7 @@
import java.util.zip.DataFormatException;
import org.opends.server.replication.common.MultiDomainServerState;
+import org.opends.server.types.DN;
import org.opends.server.types.DirectoryException;
/**
@@ -43,7 +44,7 @@
private final LDAPUpdateMsg updateMsg;
/** The baseDN of the domain to which applies the change. */
- private final String baseDN;
+ private final DN baseDN;
/** The value of the cookie updated with the current change. */
private MultiDomainServerState cookie;
@@ -59,7 +60,7 @@
* @param changeNumber The provided change number.
*/
public ECLUpdateMsg(LDAPUpdateMsg updateMsg, MultiDomainServerState cookie,
- String baseDN, long changeNumber)
+ DN baseDN, long changeNumber)
{
this.cookie = cookie;
this.baseDN = baseDN;
@@ -98,7 +99,7 @@
// Decode the baseDN
length = getNextLength(in, pos);
- this.baseDN = new String(in, pos, length, "UTF-8");
+ this.baseDN = DN.decode(new String(in, pos, length, "UTF-8"));
pos += length + 1;
// Decode the changeNumber
@@ -148,7 +149,7 @@
*
* @return The baseDN.
*/
- public String getBaseDN()
+ public DN getBaseDN()
{
return baseDN;
}
--
Gitblit v1.10.0