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 2018/02/26 18:23:29 UTC
svn commit: r1825393 -
/uima/uima-as/branches/uima-as-3/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
Author: cwiklik
Date: Mon Feb 26 18:23:28 2018
New Revision: 1825393
URL: http://svn.apache.org/viewvc?rev=1825393&view=rev
Log:
UIMA-5280 modified to use Transport.JMS property
Modified:
uima/uima-as/branches/uima-as-3/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
Modified: uima/uima-as/branches/uima-as-3/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
URL: http://svn.apache.org/viewvc/uima/uima-as/branches/uima-as-3/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java?rev=1825393&r1=1825392&r2=1825393&view=diff
==============================================================================
--- uima/uima-as/branches/uima-as-3/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java (original)
+++ uima/uima-as/branches/uima-as-3/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java Mon Feb 26 18:23:28 2018
@@ -45,6 +45,7 @@ import java.util.concurrent.atomic.Atomi
import org.apache.uima.UIMAFramework;
import org.apache.uima.aae.client.UimaAsBaseCallbackListener;
import org.apache.uima.aae.client.UimaAsynchronousEngine;
+import org.apache.uima.aae.client.UimaAsynchronousEngine.Transport;
import org.apache.uima.adapter.jms.JmsConstants;
import org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngine_impl;
import org.apache.uima.analysis_engine.AnalysisEngineServiceStub;
@@ -155,6 +156,8 @@ public class JmsAnalysisEngineServiceStu
appCtxt.put(UimaAsynchronousEngine.ServerUri, brokerUrl);
appCtxt.put(UimaAsynchronousEngine.ENDPOINT, endpoint);
appCtxt.put(UimaAsynchronousEngine.CasPoolSize, 0);
+ appCtxt.put(UimaAsynchronousEngine.ClientTransport, Transport.JMS);
+
if (timeout > 0) {
appCtxt.put(UimaAsynchronousEngine.Timeout, timeout);
}
@@ -168,6 +171,8 @@ public class JmsAnalysisEngineServiceStu
appCtxt.put(UimaAsynchronousEngine.SERIALIZATION_STRATEGY, "binary");
}
uimaEEEngine = new BaseUIMAAsynchronousEngine_impl();
+ System.out.println("::::::::::::::::JmsAdapter uimaEEEngine.hashCode():"+uimaEEEngine.hashCode());
+
uimaEEEngine.addStatusCallbackListener(this);
uimaEEEngine.initialize(appCtxt);
enginemap.put(brokerUrl+endpoint, uimaEEEngine);