Skip to content
Snippets Groups Projects
Commit 320b4a92 authored by anttil's avatar anttil
Browse files

BIS-298 / SP-447: Refactor for clarity: No payload means: an exception has occured here.

SVN: 28062
parent a4d0ee16
No related branches found
No related tags found
No related merge requests found
...@@ -24,8 +24,8 @@ import ch.systemsx.cisd.common.serviceconversation.IServiceMessageTransport; ...@@ -24,8 +24,8 @@ import ch.systemsx.cisd.common.serviceconversation.IServiceMessageTransport;
import ch.systemsx.cisd.common.serviceconversation.ServiceMessage; 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 * @author Bernd Rinn
*/ */
class ClientResponseMessageQueue implements IServiceMessageTransport class ClientResponseMessageQueue implements IServiceMessageTransport
...@@ -39,7 +39,7 @@ class ClientResponseMessageQueue implements IServiceMessageTransport ...@@ -39,7 +39,7 @@ class ClientResponseMessageQueue implements IServiceMessageTransport
{ {
return messageQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS); return messageQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS);
} }
@Override @Override
public void send(ServiceMessage message) public void send(ServiceMessage message)
{ {
...@@ -50,7 +50,7 @@ class ClientResponseMessageQueue implements IServiceMessageTransport ...@@ -50,7 +50,7 @@ class ClientResponseMessageQueue implements IServiceMessageTransport
{ {
messageIdxLastSeen = message.getMessageIdx(); messageIdxLastSeen = message.getMessageIdx();
} }
if (message.hasPayload() == false) if (message.isException())
{ {
messageQueue.clear(); messageQueue.clear();
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment