From 84cf626ebcae1b535abe9efd3eed5cdf78bdd319 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 05 Sep 2013 07:51:54 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDraftCNKey.java | 16 ++++++++++++++--
1 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDraftCNKey.java b/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDraftCNKey.java
index e01c4a4..00229e6 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDraftCNKey.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDraftCNKey.java
@@ -31,6 +31,8 @@
import com.sleepycat.je.DatabaseEntry;
+import static org.opends.server.util.StaticUtils.*;
+
/**
* Useful to create ReplicationServer keys from sequence numbers.
*/
@@ -39,8 +41,18 @@
private static final long serialVersionUID = 1L;
/**
+ * Creates a ReplicationDraftCNKey that can start anywhere in the DB.
+ */
+ public ReplicationDraftCNKey()
+ {
+ super();
+ }
+
+ /**
* Creates a new ReplicationKey from the given change number.
- * @param changeNumber The change number to use.
+ *
+ * @param changeNumber
+ * The change number to use.
*/
public ReplicationDraftCNKey(long changeNumber)
{
@@ -63,6 +75,6 @@
*/
public long getChangeNumber()
{
- return Long.valueOf(new String(getData()));
+ return Long.valueOf(decodeUTF8(getData()));
}
}
--
Gitblit v1.10.0