You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/07/28 17:23:42 UTC
svn commit: r798558 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java
Author: cwiklik
Date: Tue Jul 28 15:23:42 2009
New Revision: 798558
URL: http://svn.apache.org/viewvc?rev=798558&view=rev
Log:
UIMA-1436 Acquire getMeta semaphore before sending getMeta request
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java?rev=798558&r1=798557&r2=798558&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java Tue Jul 28 15:23:42 2009
@@ -521,6 +521,13 @@
sharedConnection.incrementClientCount();
}
running = true;
+ // Acquire GetMeta Semaphore Before Sending a GetMeta Request. This will force
+ // the client to block in waitForMetadataReply() until GetMeta reply is received
+ try {
+ getMetaSemaphore.acquire();
+ } catch( InterruptedException e) {
+ System.out.println("UIMA AS Client Interrupted While Waiting On GetMetaSemaphore");
+ }
sendMetaRequest();
waitForMetadataReply();
if (abort || !running)