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