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/ECLServerWriter.java | 7 ++-----
1 files changed, 2 insertions(+), 5 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java
index 5388c55..c718865 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerWriter.java
@@ -64,7 +64,6 @@
private ProtocolSession session;
private ECLServerHandler handler;
private ReplicationServerDomain replicationServerDomain;
- private short protocolVersion = -1;
private boolean suspended;
private boolean shutdown;
private PersistentSearch mypsearch;
@@ -88,8 +87,6 @@
this.session = session;
this.handler = handler;
this.replicationServerDomain = replicationServerDomain;
- // Keep protocol version locally for efficiency
- this.protocolVersion = handler.getProtocolVersion();
this.suspended = false;
this.shutdown = false;
@@ -249,7 +246,7 @@
// Done is used to end phase 1
session.publish(new DoneMsg(
handler.getReplicationServerId(),
- handler.getServerId()), protocolVersion);
+ handler.getServerId()));
}
}
@@ -295,7 +292,7 @@
if (session!=null)
{
- session.publish(msg, protocolVersion);
+ session.publish(msg);
}
else
{
--
Gitblit v1.10.0