| File was renamed from opends/src/server/org/opends/server/synchronization/AckMessage.java |
| | |
| | | * |
| | | * 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; |
| | | |
| | |
| | | * {@inheritDoc} |
| | | */ |
| | | @Override |
| | | public UpdateMessage processReceive(SynchronizationDomain domain) |
| | | { |
| | | domain.receiveAck(this); |
| | | return null; |
| | | } |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | @Override |
| | | public byte[] getBytes() |
| | | { |
| | | try |