Skip to content
Snippets Groups Projects
Commit 9bffed0d authored by brinn's avatar brinn
Browse files

Should not check for service exception when calling terminate().

SVN: 24049
parent 096ea28a
No related branches found
No related tags found
No related merge requests found
...@@ -82,12 +82,6 @@ class ClientMessenger implements IServiceConversation ...@@ -82,12 +82,6 @@ class ClientMessenger implements IServiceConversation
nextOutgoingMessageIndex(), false, message)); nextOutgoingMessageIndex(), false, message));
} }
public void terminate()
{
checkServiceException();
transportToService.send(ServiceMessage.terminate(serviceConversationId));
}
private void checkServiceException() throws ServiceExecutionException private void checkServiceException() throws ServiceExecutionException
{ {
if (serviceExceptionSignaled.getAndSet(false)) if (serviceExceptionSignaled.getAndSet(false))
...@@ -107,6 +101,11 @@ class ClientMessenger implements IServiceConversation ...@@ -107,6 +101,11 @@ class ClientMessenger implements IServiceConversation
} }
} }
public void terminate()
{
transportToService.send(ServiceMessage.terminate(serviceConversationId));
}
public <T extends Serializable> T receive(Class<T> messageClass) public <T extends Serializable> T receive(Class<T> messageClass)
{ {
try try
......
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