From 6c857f852f405a08653a4cfd86cc0257e7df486d Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Wed, 19 Jun 2013 08:36:16 +0000
Subject: [PATCH] Fix OPENDJ-986: Exception when reading messages from Replication server RS
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerWriter.java | 7 ++-----
1 files changed, 2 insertions(+), 5 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerWriter.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerWriter.java
index 402d6e4..4aae7d7 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerWriter.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerWriter.java
@@ -23,7 +23,7 @@
*
*
* Copyright 2006-2009 Sun Microsystems, Inc.
- * Portions Copyright 2011 ForgeRock AS
+ * Portions Copyright 2011-2013 ForgeRock AS
*/
package org.opends.server.replication.server;
import org.opends.messages.Message;
@@ -58,7 +58,6 @@
private final ProtocolSession session;
private final ServerHandler handler;
private final ReplicationServerDomain replicationServerDomain;
- private final short protocolVersion;
@@ -88,8 +87,6 @@
this.session = session;
this.handler = handler;
this.replicationServerDomain = replicationServerDomain;
- // Keep protocol version locally for efficiency
- this.protocolVersion = handler.getProtocolVersion();
}
/**
@@ -194,7 +191,7 @@
// Publish the update to the remote server using a protocol version he
// it supports
- session.publish(update, protocolVersion);
+ session.publish(update);
}
}
catch (NoSuchElementException e)
--
Gitblit v1.10.0