svn commit: r737209 - /incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java

[ea...@apache.org]

Author: eae
Date: Fri Jan 23 14:23:45 2009
New Revision: 737209

URL: http://svn.apache.org/viewvc?rev=737209&view=rev
Log:
UIMA-1274

Modified:
    incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java

Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java?rev=737209&r1=737208&r2=737209&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java Fri Jan 23 14:23:45 2009
@@ -62,6 +62,7 @@
   public static final String PARAM_BROKER_URL = "brokerUrl";
   public static final String PARAM_ENDPOINT = "endpoint";
   public static final String PARAM_TIMEOUT = "timeout";
+  public static final String PARAM_BIN_SERIALIZTION = "binary_serialization";
   private Object mux = new Object();
   private boolean cpcReceived;
   private UimaAsynchronousEngine uimaEEEngine;
@@ -72,6 +73,7 @@
     String brokerUrl = null;
     String endpoint = null;
     int timeout = 0;
+    String binary_serialization = null;
     for (int i = 0; i < parameters.length; i++) {
       if (PARAM_BROKER_URL.equalsIgnoreCase(parameters[i].getName())) {
         brokerUrl = parameters[i].getValue();
@@ -82,6 +84,9 @@
       else if (PARAM_TIMEOUT.equalsIgnoreCase(parameters[i].getName())) {
         timeout = Integer.parseInt(parameters[i].getValue());
       }
+      else if (PARAM_BIN_SERIALIZTION.equalsIgnoreCase(parameters[i].getName())) {
+        binary_serialization = parameters[i].getValue();
+      }
     }
     
     // initialize UIMA EE Engine
@@ -93,6 +98,10 @@
       System.out.println("setting timeout: " + timeout);
       appCtxt.put(UimaAsynchronousEngine.Timeout, timeout);
     }
+    if (binary_serialization != null && binary_serialization.equalsIgnoreCase("true")) {
+      System.out.println("Using binary serialization");
+      appCtxt.put(UimaAsynchronousEngine.SerializationStrategy, "binary");
+    }
     uimaEEEngine = new BaseUIMAAsynchronousEngine_impl();
     uimaEEEngine.addStatusCallbackListener(this);
     uimaEEEngine.initialize(appCtxt);