From 7adb93986ace907531875e25be1f94d735fbb068 Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Mon, 08 Dec 2008 08:03:33 +0000
Subject: [PATCH] Merge the replication-service branch with the OpenDS trunk
---
opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java
index 8993a13..1899935 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java
@@ -25,6 +25,8 @@
* Copyright 2006-2008 Sun Microsystems, Inc.
*/
package org.opends.server.replication.plugin;
+import org.opends.server.replication.protocol.LDAPUpdateMsg;
+
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import org.opends.messages.Message;
@@ -37,7 +39,6 @@
import org.opends.server.api.DirectoryThread;
import org.opends.server.loggers.debug.DebugTracer;
-import org.opends.server.replication.protocol.UpdateMsg;
/**
* Thread that is used to get message from the replication servers (stored
@@ -102,8 +103,8 @@
TimeUnit.SECONDS)) != null))
{
// Find replication domain for that update message
- UpdateMsg updateMsg = updateToreplay.getUpdateMessage();
- ReplicationDomain domain = updateToreplay.getReplicationDomain();
+ LDAPUpdateMsg updateMsg = updateToreplay.getUpdateMessage();
+ LDAPReplicationDomain domain = updateToreplay.getReplicationDomain();
domain.replay(updateMsg);
}
} catch (Exception e)
--
Gitblit v1.10.0