From 693421b38b25cf570415fbb205a78948c32afeb9 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 26 Mar 2013 16:57:29 +0000
Subject: [PATCH] OPENDJ-832 Leverage the work queue for processing requests received on the HTTP connection handler
---
opends/src/server/org/opends/server/replication/protocol/DeleteMsg.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/DeleteMsg.java b/opends/src/server/org/opends/server/replication/protocol/DeleteMsg.java
index b65f548..b036620 100644
--- a/opends/src/server/org/opends/server/replication/protocol/DeleteMsg.java
+++ b/opends/src/server/org/opends/server/replication/protocol/DeleteMsg.java
@@ -23,7 +23,7 @@
*
*
* Copyright 2006-2010 Sun Microsystems, Inc.
- * Portions Copyright 2011-2012 ForgeRock AS
+ * Portions Copyright 2011-2013 ForgeRock AS
*/
package org.opends.server.replication.protocol;
@@ -36,8 +36,8 @@
import org.opends.server.core.DeleteOperationBasis;
import org.opends.server.protocols.internal.InternalClientConnection;
import org.opends.server.replication.common.ChangeNumber;
-import org.opends.server.types.AbstractOperation;
import org.opends.server.types.ByteString;
+import org.opends.server.types.Operation;
import org.opends.server.types.operation.PostOperationDeleteOperation;
/**
@@ -47,7 +47,7 @@
{
private String initiatorsName;
- // whether the DEL operation is a subtree DEL
+ /** whether the DEL operation is a subtree DEL. */
private boolean isSubtreeDelete = false;
/**
@@ -66,7 +66,6 @@
}
catch(Exception e)
{}
-
}
/**
@@ -113,8 +112,8 @@
* {@inheritDoc}
*/
@Override
- public AbstractOperation createOperation(
- InternalClientConnection connection, String newDn)
+ public Operation createOperation(InternalClientConnection connection,
+ String newDn)
{
DeleteOperationBasis del = new DeleteOperationBasis(connection,
InternalClientConnection.nextOperationID(),
@@ -136,6 +135,7 @@
/**
* {@inheritDoc}
*/
+ @Override
public byte[] getBytes_V1() throws UnsupportedEncodingException
{
return encodeHeader_V1(MSG_TYPE_DELETE_V1, 0);
--
Gitblit v1.10.0