From 0bee1ee3a776af367c685d042155cd43ae71deab Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Mon, 13 Nov 2006 08:31:12 +0000
Subject: [PATCH] Fix for 982 : reorganize synchronization code :
---
opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/AckMessage.java | 19 ++++---------------
1 files changed, 4 insertions(+), 15 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/synchronization/AckMessage.java b/opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/AckMessage.java
similarity index 88%
rename from opendj-sdk/opends/src/server/org/opends/server/synchronization/AckMessage.java
rename to opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/AckMessage.java
index f1e72d5..cb35f38 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/synchronization/AckMessage.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/AckMessage.java
@@ -24,19 +24,18 @@
*
* Portions Copyright 2006 Sun Microsystems, Inc.
*/
-package org.opends.server.synchronization;
+package org.opends.server.synchronization.protocol;
-import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import java.util.zip.DataFormatException;
+import org.opends.server.synchronization.common.ChangeNumber;
+
/**
* Used to send acks between LDAP and changelog servers.
*/
-public class AckMessage extends SynchronizationMessage implements Serializable
+public class AckMessage extends SynchronizationMessage
{
- private static final long serialVersionUID = -8695651898339602441L;
-
// ChangeNumber of the update that was acked.
private ChangeNumber changeNumber;
@@ -92,16 +91,6 @@
* {@inheritDoc}
*/
@Override
- public UpdateMessage processReceive(SynchronizationDomain domain)
- {
- domain.receiveAck(this);
- return null;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
public byte[] getBytes()
{
try
--
Gitblit v1.10.0