From 41bef7c0b619c7bc925326451a56071b5736580a 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
---
opends/src/server/org/opends/server/replication/protocol/TLSSocketSession.java | 25 ++++++++++++-------------
1 files changed, 12 insertions(+), 13 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/TLSSocketSession.java b/opends/src/server/org/opends/server/replication/protocol/TLSSocketSession.java
index 112efab..f27c950 100644
--- a/opends/src/server/org/opends/server/replication/protocol/TLSSocketSession.java
+++ b/opends/src/server/org/opends/server/replication/protocol/TLSSocketSession.java
@@ -312,19 +312,7 @@
@Override
public void publish(final ReplicationMsg msg) throws IOException
{
- publish(msg, ProtocolVersion.getCurrentVersion());
- }
-
-
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void publish(final ReplicationMsg msg,
- final short reqProtocolVersion) throws IOException
- {
- final byte[] buffer = msg.getBytes(reqProtocolVersion);
+ final byte[] buffer = msg.getBytes(protocolVersion);
final String str = String.format("%08x", buffer.length);
final byte[] sendLengthBuf = str.getBytes();
@@ -460,6 +448,17 @@
* {@inheritDoc}
*/
@Override
+ public short getProtocolVersion()
+ {
+ return protocolVersion;
+ }
+
+
+
+ /**
+ * {@inheritDoc}
+ */
+ @Override
public void setSoTimeout(final int timeout) throws SocketException
{
plainSocket.setSoTimeout(timeout);
--
Gitblit v1.10.0