From 320b4a92661ad8487ff17df3c51055443fffd2c4 Mon Sep 17 00:00:00 2001
From: anttil <anttil>
Date: Fri, 11 Jan 2013 14:40:55 +0000
Subject: [PATCH] BIS-298 / SP-447: Refactor for clarity: No payload means: an
exception has occured here.
SVN: 28062
---
.../client/ClientResponseMessageQueue.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/common/source/java/ch/systemsx/cisd/common/serviceconversation/client/ClientResponseMessageQueue.java b/common/source/java/ch/systemsx/cisd/common/serviceconversation/client/ClientResponseMessageQueue.java
index b2693aa6b92..27536cd6d3b 100644
--- a/common/source/java/ch/systemsx/cisd/common/serviceconversation/client/ClientResponseMessageQueue.java
+++ b/common/source/java/ch/systemsx/cisd/common/serviceconversation/client/ClientResponseMessageQueue.java
@@ -24,8 +24,8 @@ import ch.systemsx.cisd.common.serviceconversation.IServiceMessageTransport;
import ch.systemsx.cisd.common.serviceconversation.ServiceMessage;
/**
- * A class that holds a queue for response messages to a client.
- *
+ * A class that holds a queue for response messages to a client.
+ *
* @author Bernd Rinn
*/
class ClientResponseMessageQueue implements IServiceMessageTransport
@@ -39,7 +39,7 @@ class ClientResponseMessageQueue implements IServiceMessageTransport
{
return messageQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS);
}
-
+
@Override
public void send(ServiceMessage message)
{
@@ -50,7 +50,7 @@ class ClientResponseMessageQueue implements IServiceMessageTransport
{
messageIdxLastSeen = message.getMessageIdx();
}
- if (message.hasPayload() == false)
+ if (message.isException())
{
messageQueue.clear();
}
--
GitLab