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 2020/06/10 13:14:46 UTC
[uima-async-scaleout] 02/34: UIMA-5280 modified to use
Transport.JMS property
This is an automated email from the ASF dual-hosted git repository.
cwiklik pushed a commit to branch uima-as-3
in repository https://gitbox.apache.org/repos/asf/uima-async-scaleout.git
commit 63db13bfceb6a5aaa92675c35f397a5df881a8e4
Author: cwiklik <cwiklik>
AuthorDate: Mon Feb 26 18:23:28 2018 +0000
UIMA-5280 modified to use Transport.JMS property
---
.../apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java b/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
index 6bda1c2..e27457b 100644
--- a/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
+++ b/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
@@ -45,6 +45,7 @@ import java.util.concurrent.atomic.AtomicInteger;
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 JmsAnalysisEngineServiceStub extends UimaAsBaseCallbackListener imp
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 JmsAnalysisEngineServiceStub extends UimaAsBaseCallbackListener imp
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);