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);