From fd7b82c90daf271ef5b7cfeee889e97712c49a99 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 21 Aug 2015 15:40:08 +0000
Subject: [PATCH] Reverted part of r12768
---
opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java b/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java
index 03ff434..18f0cd3 100644
--- a/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java
+++ b/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java
@@ -443,7 +443,7 @@
{
{
// Receive server start
- ServerStartMsg serverStartMsg = waitForSpecificMsg(session, ServerStartMsg.class);
+ ServerStartMsg serverStartMsg = (ServerStartMsg) session.receive();
baseDN = serverStartMsg.getBaseDN();
serverState = serverStartMsg.getServerState();
@@ -464,7 +464,7 @@
}
// Read start session or stop
- ReplicationMsg msg = waitForSpecificMsgs(session, StopMsg.class, ServerStartMsg.class);
+ ReplicationMsg msg = session.receive();
if (msg instanceof StopMsg){
// Disconnection of DS looking for best server
return false;
@@ -584,7 +584,7 @@
session.publish(addMsg);
// Read and return matching ack
- return waitForSpecificMsg(session, AckMsg.class);
+ return (AckMsg)session.receive();
}
}
--
Gitblit v1.10.0